distributor.distributor_workflow_run ==================================== .. py:module:: distributor.distributor_workflow_run Attributes ---------- .. autoapisummary:: distributor.distributor_workflow_run.logger Classes ------- .. autoapisummary:: distributor.distributor_workflow_run.DistributorWorkflowRun Module Contents --------------- .. py:data:: logger .. py:class:: 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 .. py:attribute:: workflow_run_id .. py:attribute:: status :value: '' .. py:attribute:: requester .. py:method:: _update_status(status: str) -> None Update the status of the workflow_run with whatever status is passed. .. py:method:: transition_to_instantiated() -> None .. py:method:: transition_to_launched() -> None .. py:method:: __hash__() -> int Returns the ID of the workflow run. .. py:method:: __eq__(other: object) -> bool Check if the hashes of two WorkflowRuns are equivalent. .. py:method:: __lt__(other: DistributorWorkflowRun) -> bool Check if one hash is less than the hash of another.