HomeElementl

RunStatusSensorDefinition and @run_status_sensor

Description

RunStatusSensorDefinition and @run_status_sensor

Summary:
depends on D8896

introducing a generic pipeline_sensor so users can define sensors that react to pipeline statuses like starting, started, success, etc
API:

@pipeline_sensor(pipeline_run_status=PipelineRunStatus.STARTED)
def my_pipeline_started_sensor(_):
    ...

it takes pipeline_run_status arg which internally will be mapped to a dagster event type (lookup in D8896)

changes on implementation details:

  • created PipelineSensorDefinition
  • built pipeline_failure_sensor on top of this generic

Test Plan: bk

Reviewers: prha, sandyryza, alangenfeld

Reviewed By: sandyryza

Differential Revision: https://dagster.phacility.com/D8900

Details

Provenance
yuhanAuthored on Jul 14 2021, 7:50 PM
Reviewer
sandyryza
Differential Revision
D8900: RunStatusSensorDefinition and @run_status_sensor
Parents
R1:19f525d6f7be: consolidate event type to run status lookup
Branches
Unknown
Tags
Unknown