Update to use slack

Author: bnchrch

airbyte-ci/connectors/metadata_service/orchestrator/orchestrator/assets/connector_test_report.py

@@ -145,7 +145,7 @@ def generate_nightly_report(context: OpExecutionContext) -> Output[pd.DataFrame]
     nightly_report_complete_md = render_connector_nightly_report_md(nightly_report_connector_matrix_df, nightly_report_complete_df)
     slack_webhook_url = os.getenv("NIGHTLY_REPORT_SLACK_WEBHOOK_URL")
     if slack_webhook_url:
-        send_slack_webhook(slack_webhook_url, nightly_report_complete_md)
+        send_slack_webhook(slack_webhook_url, nightly_report_complete_md, wrap_in_code_block=True)
 
     return Output(
         nightly_report_connector_matrix_df,

airbyte-ci/connectors/metadata_service/orchestrator/orchestrator/logging/publish_connector_lifecycle.py

@@ -63,4 +63,5 @@ def log(context: OpExecutionContext, lifecycle_stage: PublishConnectorLifecycleS
 
         slack_webhook_url = os.getenv("PUBLISH_UPDATE_SLACK_WEBHOOK_URL")
         if slack_webhook_url:
-            send_slack_webhook(slack_webhook_url, message)
+            slack_message = f"🤖 {message}"
+            send_slack_webhook(slack_webhook_url, slack_message)

airbyte-ci/connectors/metadata_service/orchestrator/orchestrator/ops/slack.py

@@ -1,4 +1,3 @@
-from dagster import op
 from slack_sdk import WebhookClient
 
 
@@ -13,9 +12,10 @@ def chunk_messages(report):
     yield msg
 
 
-@op
-def send_slack_webhook(webhook_url, report):
+def send_slack_webhook(webhook_url, report, wrap_in_code_block=False):
     webhook = WebhookClient(webhook_url)
     for msg in chunk_messages(report):
         # Wrap in code block as slack does not support markdown in webhooks
-        webhook.send(text=f"```{msg}```")
+        if wrap_in_code_block:
+            msg = f"```{msg}```"
+        webhook.send(msg)