server.workflow_reaper.reaper_workflow_run

Reaper Behavior for a given Workflow Run.

Attributes

logger

Classes

ReaperWorkflowRun

Reaper Behavior for a given Workflow Run.

Module Contents

server.workflow_reaper.reaper_workflow_run.logger[source]

class server.workflow_reaper.reaper_workflow_run.ReaperWorkflowRun(workflow_run_id: int, workflow_id: int, requester: jobmon.core.requester.Requester)[source]

Bases: object

Reaper Behavior for a given Workflow Run.

workflow_run_id[source]

workflow_id[source]

_requester[source]

classmethod from_wire(wire_tuple: tuple, requester: jobmon.core.requester.Requester) → ReaperWorkflowRun[source]: Create Reaper Workflow Run object.

reap() → str[source]: Transition workflow run to error.

__repr__() → str[source]: Return formatted reaper workflow run data.