update context method in email sensor

dagster-io · Nov 6, 2023 · e604bfa · e604bfa
1 parent 684a01c
commit e604bfa
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/python_modules/dagster/dagster/_utils/alert.py b/python_modules/dagster/dagster/_utils/alert.py
@@ -22,7 +22,7 @@ def _default_failure_email_body(context: "RunFailureSensorContext") -> str:
 
     return "<br>".join(
         [
-            f"Pipeline {context.dagster_run.job_name} failed!",
+            f"Job {context.dagster_run.job_name} failed!",
             f"Run ID: {context.dagster_run.run_id}",
             f"Mode: {DEFAULT_MODE_NAME}",
             f"Error: {context.failure_event.message}",
@@ -31,7 +31,7 @@ def _default_failure_email_body(context: "RunFailureSensorContext") -> str:
 
 
 def _default_failure_email_subject(context) -> str:
-    return f"Dagster Run Failed: {context.pipeline_run.job_name}"
+    return f"Dagster Run Failed: {context.dagster_run.job_name}"
 
 
 EMAIL_MESSAGE = """From: {email_from}
@@ -165,7 +165,7 @@ def my_repo():
 
             def my_message_fn(context: RunFailureSensorContext) -> str:
                 return (
-                    f"Job {context.pipeline_run.job_name} failed!"
+                    f"Job {context.dagster_run.job_name} failed!"
                     f"Error: {context.failure_event.message}"
                 )