Stephen Bailey
08/26/2022, 11:01 AM@run_status_sensor(run_status=DagsterRunStatus.SUCCESS)
def my_slack_on_run_success(context: RunStatusSensorContext):
slack_client = WebClient(token=os.environ["SLACK_DAGSTER_ETL_BOT_TOKEN"])
slack_client.chat_postMessage(
channel="#alert-channel",
message=f'Job "{context.dagster_run.job_name}" succeeded.',
)
yield SuccessMessage("Posted to Slack!")
Stephen Bailey
08/26/2022, 11:03 AMsandy
08/26/2022, 3:42 PM