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

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

Bases: object

Reaper Behavior for a given Workflow Run.

Implementing workflow reaper behavior of workflow run.

Parameters:

• workflow_run_id (int) – id of workflow run object from DB.

• workflow_id (int) – id of associated workflow.

• requester (Requester) – requester to communicate with Flask.

workflow_run_id

workflow_id

classmethod from_wire(wire_tuple: tuple, requester: jobmon.core.requester.Requester) → ReaperWorkflowRun

Create Reaper Workflow Run object.

reap() → str

Transition workflow run to error.