adding task in master dag to check encoding

astronomer · Jan 11, 2024 · 6469bb6 · 6469bb6
1 parent a49fe81
commit 6469bb6
Showing 1 changed file with 12 additions and 2 deletions.
diff --git 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(