Adding tojson filter to example_inlet_event_extra example dag (apache…

…#41873)
MRLab12 · Aug 30, 2024 · 87a4a51 · 87a4a51
1 parent 9e40107
commit 87a4a51
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/example_dags/example_inlet_event_extra.py b/airflow/example_dags/example_inlet_event_extra.py
@@ -57,5 +57,5 @@ def read_dataset_event(*, inlet_events=None):
     BashOperator(
         task_id="read_dataset_event_from_classic",
         inlets=[ds],
-        bash_command="echo {{ inlet_events['s3://output/1.txt'][-1].extra }}",
+        bash_command="echo '{{ inlet_events['s3://output/1.txt'][-1].extra | tojson }}'",
     )