From 4208201398e5ee5ea2ccc50f2e72e06203fdbd9a Mon Sep 17 00:00:00 2001 From: vatsrahul1001 <43964496+vatsrahul1001@users.noreply.github.com> Date: Tue, 16 Jan 2024 15:04:40 +0530 Subject: [PATCH] adding bash task for non ascii char (#1429) PR introduced a bug due to which the airflow version was getting displayed incorrectly --- .circleci/integration-tests/master_dag.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/.circleci/integration-tests/master_dag.py b/.circleci/integration-tests/master_dag.py index a5210a0d1..eb2eb6aab 100644 --- a/.circleci/integration-tests/master_dag.py +++ b/.circleci/integration-tests/master_dag.py @@ -187,8 +187,11 @@ def prepare_dag_dependency(task_info, execution_time): ) get_airflow_version = BashOperator( - task_id="get_airflow_version", bash_command="airflow version && echo åäö", do_xcom_push=True + task_id="get_airflow_version", bash_command="airflow version", do_xcom_push=True ) + + print_non_ascii_data = BashOperator(task_id="print_non_ascii_data", bash_command="echo åäö") + check_logs_data = PythonOperator( task_id="check_logs", python_callable=check_log, @@ -206,13 +209,13 @@ def prepare_dag_dependency(task_info, execution_time): task_id="check_non_ascii_data", python_callable=check_log, op_args=[ - "get_airflow_version", + "print_non_ascii_data", "åäö", "this_string_should_not_be_present_in_logs", ], ) - airflow_version_check = (get_airflow_version, check_logs_data, check_non_ascii_data) + airflow_version_check = (get_airflow_version, check_logs_data, print_non_ascii_data, check_non_ascii_data) chain(*airflow_version_check) get_airflow_executor = BashOperator(