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[source]

class distributor.distributor_workflow_run.DistributorWorkflowRun(workflow_run_id: int, requester: jobmon.core.requester.Requester)[source]

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

workflow_run_id[source]

status = ''[source]

requester[source]

_update_status(status: str) → None[source]: Update the status of the workflow_run with whatever status is passed.

transition_to_instantiated() → None[source]

transition_to_launched() → None[source]

__hash__() → int[source]: Returns the ID of the workflow run.

__eq__(other: object) → bool[source]: Check if the hashes of two WorkflowRuns are equivalent.

__lt__(other: DistributorWorkflowRun) → bool[source]: Check if one hash is less than the hash of another.