Skip to content

Commit

Permalink
adding bash task for non ascii char (#1429)
Browse files Browse the repository at this point in the history
PR introduced a bug due to which the airflow version was getting displayed incorrectly
  • Loading branch information
vatsrahul1001 authored Jan 16, 2024
1 parent e3ac9bc commit 4208201
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions .circleci/integration-tests/master_dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand All @@ -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(
Expand Down

0 comments on commit 4208201

Please sign in to comment.