HomeElementl

slack pipeline_failure_sensor

Description

slack pipeline_failure_sensor

Summary:
make_slack_on_pipeline_failure_sensor
^ api pair with slack_on_failure (here)

doc:

image.png (2×1 px, 431 KB)

slack_on_pipeline_failure = make_slack_on_pipeline_failure_sensor(
    "#yuhan-test",
    os.getenv("SLACK_DAGSTER_ETL_BOT_TOKEN"),
    dagit_base_url="http://localhost:3000",

@repository
def my_repo():
    return [my_pipeline, slack_on_pipeline_failure]

slack msg:

Screen Shot 2021-06-23 at 11.37.24 PM.png (304×1 px, 79 KB)

Test Plan:
unit test for def
toy sensor worked in dagit

Reviewers: sandyryza, prha, owen

Reviewed By: sandyryza

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

Details

Provenance
yuhanAuthored on Jun 24 2021, 6:38 AM
Reviewer
sandyryza
Differential Revision
D8510: slack pipeline_failure_sensor
Parents
R1:8d009a51c952: remove rc docs
Branches
Unknown
Tags
Unknown