fix: on failure job sensor

JasperHG90 · Feb 2, 2024 · 5a4d8ab · 5a4d8ab
1 parent 43ed8b4
commit 5a4d8ab
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py b/dags/luchtmeetnet_ingestion/src/luchtmeetnet_ingestion/sensors.py
@@ -42,12 +42,7 @@ def slack_message_on_success(context: RunStatusSensorContext, slack: SlackResour
     default_status=DefaultSensorStatus.RUNNING,
 )
 def slack_message_on_failure(context: RunFailureSensorContext, slack: SlackResource):
-    message = (
-        (
-            f'Job "{context.dagster_run.job_name}" with ID "{context.dagster_run.run_id}" failed. Error Message:'
-            f" {context.failure_event.message}"
-        ),
-    )
+    message = f'Job "{context.dagster_run.job_name}" with ID "{context.dagster_run.run_id}" failed. Error Message: {context.failure_event.message}"'
     if environment == "dev":
         context.log.info(message)
     else: