From 6469bb66e49d7a81657d1c56425ae6a36c8fa9de Mon Sep 17 00:00:00 2001 From: vatsrahul1001 Date: Thu, 11 Jan 2024 12:55:55 +0530 Subject: [PATCH] adding task in master dag to check encoding --- .circleci/integration-tests/master_dag.py | 14 ++++++++++++-- 1 file changed, 12 insertions(+), 2 deletions(-) diff --git a/.circleci/integration-tests/master_dag.py b/.circleci/integration-tests/master_dag.py index cf22ba883..ff829fe69 100644 --- a/.circleci/integration-tests/master_dag.py +++ b/.circleci/integration-tests/master_dag.py @@ -187,7 +187,7 @@ def prepare_dag_dependency(task_info, execution_time): ) get_airflow_version = BashOperator( - task_id="get_airflow_version", bash_command="airflow version", do_xcom_push=True + task_id="get_airflow_version", bash_command="airflow version && echo åäö", do_xcom_push=True ) check_logs_data = PythonOperator( task_id="check_logs", @@ -199,7 +199,17 @@ def prepare_dag_dependency(task_info, execution_time): ], ) - airflow_version_check = (get_airflow_version, check_logs_data) + check_encoded_data = PythonOperator( + task_id="check_logs", + python_callable=check_log, + op_args=[ + "get_airflow_version", + "åäö", + "this_string_should_not_be_present_in_logs", + ], + ) + + airflow_version_check = (get_airflow_version, check_logs_data, check_encoded_data) chain(*airflow_version_check) get_airflow_executor = BashOperator(