Work Distribution

olympus.dashboard.plots.work_distribution.plot_gantt_plotly(jobs, annotations=None, resources=None)

Returns a Gantt diagram representing how the work was scheduler among the different workers

Examples

jobs = [
    dict(Task='worker-0', Start=0, Finish=1, Resource='Trial'),
    dict(Task='worker-1', Start=1, Finish=2, Resource='HPO'),
    dict(Task='worker-0', Start=0, Finish=1, Resource='Trial'),
    dict(Task='worker-1', Start=1, Finish=2, Resource='Trial'),
]

fig = plot_gantt_plotly(jobs)

olympus.dashboard.plots.work_distribution.prepare_gantt_array(work_items, worker_count)

Returns:

jobs: [{Task, Start, Finish, Resource}]

annotations: [{x, y, text}]

Examples

messages = monitor.messages(queue, namespace)
_, _ = prepare_gantt_array(*extract_work_messages(messages))