https://dagster.io/ logo
Title
m

Marcel M

11/22/2021, 11:50 AM
May have found a run status sensor buglet I have a run_status_sensor that is correctly triggered on completion.:
@run_status_sensor(pipeline_run_status=PipelineRunStatus.SUCCESS)
def sensor_on_run_success(context: RunStatusSensorContext):
    print(f"Sensing Success of pipeline: {context.pipeline_run.pipeline_name}")
The logs however show it as “failure”:
2021-11-22 12:44:38 - SensorDaemon - INFO - Completed a reaction request for run fa8e1c61-71f6-40f1-a932-e95ef472c802: Sensor "sensor_on_run_success" processed failure of run fa8e1c61-71f6-40f1-a932-e95ef472c802.
So the sensor works correctly but the log is wrong.
p

prha

11/22/2021, 5:13 PM
@yuhan
y

yuhan

11/22/2021, 5:18 PM
~Hi Marcel, are you referring to the wording “processed failure of run”? The log message indicates sensor request completion - it is saying the sensor has completed the request which processed the run failure.~
sorry misread the code. yes, it's a bug in the log message. thanks for reporting! will put up a fix soon
@Dagster Bot issue Run status sensor log message always mentions failure regardless of status type
d

Dagster Bot

11/22/2021, 6:19 PM
m

Marcel M

11/24/2021, 9:46 PM
Thx!
y

yuhan

11/24/2021, 9:53 PM
FYI: I landed a fix this week and it will go out with our next week’s release