topsim.core.planner.WorkflowPlan

class topsim.core.planner.WorkflowPlan(id, est, eft, tasks, exec_order, status, max_ingest, graph=None)[source]

WorkflowPlans are used within the Planner, Scheduler, and Cluster. They are higher-level than the shadow library representation, as they are a storage component of scheduled tasks, rather than directly representing the DAG nature of the workflow. This is why the tasks are stored in queues.

Methods

`__init__`(id, est, eft, tasks, exec_order, ...)
`get_data_cost`(task_u, task_v)
`get_task_predecessors`(task_id)
`get_task_successors`(task_id)
`is_finished`()	Check if the workflow has been marked as finished
`set_workflow_status`(status)	Update workflow status :param status: