diff --git a/.circleci/integration-tests/master_dag.py b/.circleci/integration-tests/master_dag.py index ff829fe69..097fb20d0 100644 --- a/.circleci/integration-tests/master_dag.py +++ b/.circleci/integration-tests/master_dag.py @@ -200,7 +200,7 @@ def prepare_dag_dependency(task_info, execution_time): ) check_encoded_data = PythonOperator( - task_id="check_logs", + task_id="check_encoded_data", python_callable=check_log, op_args=[ "get_airflow_version",