Connection 'get' fix

datacoves · Feb 23, 2024 · cf76b36 · cf76b36
1 parent ac0a3bd
commit cf76b36
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(conn_id="AIRBYTE_CONNECTION")
+airbyte_connection = Connection.get_connection(conn_id="AIRBYTE_CONNECTION")
 
 @dag(
     default_args={"start_date": "2021-01"},