Marcel M
11/22/2021, 11:50 AM@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.prha
11/22/2021, 5:13 PMyuhan
11/22/2021, 5:18 PMDagster Bot
11/22/2021, 6:19 PMMarcel M
11/24/2021, 9:46 PMyuhan
11/24/2021, 9:53 PM