Update slack op (#2025)

astronomer · Aug 30, 2023 · b655a6d · b655a6d
1 parent c4bccf8
commit b655a6d
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/python-sdk/tests_integration/astro_deploy/Dockerfile b/python-sdk/tests_integration/astro_deploy/Dockerfile
@@ -17,7 +17,7 @@ ENV SETUPTOOLS_USE_DISTUTILS=stdlib
 
 COPY python-sdk /tmp/python-sdk
 RUN pip install /tmp/python-sdk[all]
-RUN pip install apache-airflow[slack]
+RUN pip install "apache-airflow-providers-slack>=8.0.0"
 
 RUN mkdir -p ${AIRFLOW_HOME}/dags
 RUN mkdir -p ${AIRFLOW_HOME}/tests

diff --git a/python-sdk/tests_integration/astro_deploy/Dockerfile.single_worker b/python-sdk/tests_integration/astro_deploy/Dockerfile.single_worker
@@ -17,7 +17,7 @@ ENV SETUPTOOLS_USE_DISTUTILS=stdlib
 
 COPY python-sdk /tmp/python-sdk
 RUN pip install /tmp/python-sdk[all]
-RUN pip install apache-airflow[slack]
+RUN pip install "apache-airflow-providers-slack>=8.0.0"
 
 RUN mkdir -p ${AIRFLOW_HOME}/dags
 RUN mkdir -p ${AIRFLOW_HOME}/tests

diff --git a/python-sdk/tests_integration/astro_deploy/master_dag.py b/python-sdk/tests_integration/astro_deploy/master_dag.py
@@ -5,13 +5,13 @@
 from typing import Any, List
 
 from airflow import DAG, settings
-from airflow.contrib.operators.slack_webhook_operator import SlackWebhookOperator
 from airflow.models import Connection, DagRun
 from airflow.models.baseoperator import chain
 from airflow.operators.bash import BashOperator
 from airflow.operators.dummy import DummyOperator
 from airflow.operators.python import PythonOperator, get_current_context
 from airflow.operators.trigger_dagrun import TriggerDagRunOperator
+from airflow.providers.slack.operators.slack_webhook import SlackWebhookOperator
 from airflow.utils.session import create_session
 
 SLACK_CHANNEL = os.getenv("SLACK_CHANNEL", "#provider-alert")
@@ -118,7 +118,7 @@ def get_report(dag_run_ids: List[str], **context: Any) -> None:  # noqa: C901
         try:
             SlackWebhookOperator(
                 task_id="slack_alert",
-                http_conn_id=SLACK_WEBHOOK_CONN,
+                slack_webhook_conn_id=SLACK_WEBHOOK_CONN,
                 message="".join(output_list),
                 channel=SLACK_CHANNEL,
                 username=SLACK_USERNAME,

diff --git a/python-sdk/tests_integration/astro_deploy/master_dag_single_worker.py b/python-sdk/tests_integration/astro_deploy/master_dag_single_worker.py
@@ -5,13 +5,13 @@
 from typing import Any, List
 
 from airflow import DAG
-from airflow.contrib.operators.slack_webhook_operator import SlackWebhookOperator
 from airflow.models import DagRun
 from airflow.models.baseoperator import chain
 from airflow.operators.bash import BashOperator
 from airflow.operators.dummy import DummyOperator
 from airflow.operators.python import PythonOperator
 from airflow.operators.trigger_dagrun import TriggerDagRunOperator
+from airflow.providers.slack.operators.slack_webhook import SlackWebhookOperator
 from airflow.utils.session import create_session
 
 SLACK_CHANNEL = os.getenv("SLACK_CHANNEL", "#provider-alert")
@@ -49,7 +49,7 @@ def get_report(dag_run_ids: List[str], **context: Any) -> None:  # noqa: C901
         try:
             SlackWebhookOperator(
                 task_id="slack_alert",
-                http_conn_id=SLACK_WEBHOOK_CONN,
+                slack_webhook_conn_id=SLACK_WEBHOOK_CONN,
                 message="".join(message_list),
                 channel=SLACK_CHANNEL,
                 username=SLACK_USERNAME,