fix nuke dag failure + add cloud ui deployment link in slack notifica…

…tion
astronomer · Dec 18, 2023 · 69e40b4 · 69e40b4
1 parent cf7db12
commit 69e40b4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/.circleci/integration-tests/master_dag.py b/.circleci/integration-tests/master_dag.py
@@ -81,8 +81,9 @@ def get_report(dag_run_ids: List[str], **context: Any) -> None:
         report_details.insert(0, "Results generated for:\n\n")
         report_details.append("\n")  # Adding an additional newline at the end
 
+        cloud_ui_deployment_link = os.getenv("AIRFLOW__ASTRONOMER__CLOUD_UI_URL", None)
         master_dag_deployment_link = f"{os.environ['AIRFLOW__WEBSERVER__BASE_URL']}/dags/example_master_dag/grid?search=example_master_dag"
-        deployment_message = f"\n <{master_dag_deployment_link}|Link> to the master DAG for the above run on Astro Cloud deployment \n"
+        deployment_message = f"\n <{master_dag_deployment_link}|Link> to the master DAG for the above run on <{cloud_ui_deployment_link}|Astro Cloud deployment> \n"
 
         dag_count, failed_dag_count = 0, 0
         for dr in last_dags_runs:

diff --git a/astronomer/providers/amazon/aws/example_dags/example_aws_nuke.py b/astronomer/providers/amazon/aws/example_dags/example_aws_nuke.py
@@ -69,7 +69,7 @@ def generate_task_report(**context: Any) -> None:
         # Send the report as a Slack message
         SlackWebhookOperator(
             task_id="send_slack_report",
-            http_conn_id=SLACK_WEBHOOK_CONN,
+            slack_webhook_conn_id=SLACK_WEBHOOK_CONN,
             message=report,
             channel=SLACK_CHANNEL,
             username=SLACK_USERNAME,