proper get_connection_from_secrets method

datacoves · Feb 23, 2024 · 034ded1 · 034ded1
1 parent cf76b36
commit 034ded1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/orchestrate/dags/connections.py b/orchestrate/dags/connections.py
@@ -2,7 +2,7 @@
 from operators.datacoves.bash import DatacovesBashOperator
 from airflow.models import Connection
 
-airbyte_connection = Connection.get_connection(conn_id="AIRBYTE_CONNECTION")
+airbyte_connection = Connection.get_connection_from_secrets(conn_id="AIRBYTE_CONNECTION")
 
 @dag(
     default_args={"start_date": "2021-01"},