Alfie Johnson
07/28/2023, 12:12 PMfrom dagster import run_status_sensor, RunStatusSensorContext, DagsterRunStatus
@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.',
)
I think that the second argument for the chat_postMessage method should be text
rather than message
. I have checked the arguments used for make_slack_on_run_failure_sensor
here, and that also uses text
.sandy
07/28/2023, 11:14 PM