distributor.distributor_workflow_run

Attributes

logger

Classes

DistributorWorkflowRun

Implements workflow level bulk routes and tracks the in memory state on the distributor.

Module Contents

distributor.distributor_workflow_run.logger

class distributor.distributor_workflow_run.DistributorWorkflowRun(workflow_run_id: int, requester: jobmon.core.requester.Requester)

Implements workflow level bulk routes and tracks the in memory state on the distributor.

when polling from the database we should work in task space and translate into array space in memory where appropriate.

when pushing to the database we should work in CommandType (Workflow/Array/Task) space

Initialization of DistributorWorkflowRun object.

workflow_run_id

status = ''

requester

transition_to_instantiated() → None

transition_to_launched() → None