From 87a4a5137519448cfff85fc506b9267ec3e18364 Mon Sep 17 00:00:00 2001 From: Amogh Desai Date: Fri, 30 Aug 2024 18:14:25 +0530 Subject: [PATCH] Adding tojson filter to example_inlet_event_extra example dag (#41873) --- airflow/example_dags/example_inlet_event_extra.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/example_dags/example_inlet_event_extra.py b/airflow/example_dags/example_inlet_event_extra.py index 471a215532b47..4b7567fc2f87e 100644 --- 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 }}'", )