diff --git a/orchestrate/dags/connections.py b/orchestrate/dags/connections.py index 4d5253c9..b6ff03e3 100644 --- a/orchestrate/dags/connections.py +++ b/orchestrate/dags/connections.py @@ -13,7 +13,7 @@ ) def connections_dag(): echo_airbyte_host = DatacovesBashOperator( - task_id="transform", + task_id="echo_airbyte_host", bash_command=f"echo 'Airbyte hostname is {airbyte_connection.host}'", )