task_workflow

superduper.jobs.task_workflow

Source code

TaskWorkflow

TaskWorkflow(self,
     database: 'Datalayer',
     G: 'DiGraph' = None) -> None

Parameter	Description
database	DB instance to use
G	networkx.DiGraph to use as the graph

Task workflow class.

Keep a graph of jobs that need to be performed and their dependencies, and perform them when called.