From 09ec2616568f8a18e0d5fe408110fae06ddf748f Mon Sep 17 00:00:00 2001 From: Jarek Potiuk Date: Fri, 30 Aug 2024 14:49:01 +0200 Subject: [PATCH] Adding tojson filter to example_inlet_event_extra example dag (#41873) (#41890) (cherry picked from commit 87a4a5137519448cfff85fc506b9267ec3e18364) Co-authored-by: Amogh Desai --- 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 471a215532b4..4b7567fc2f87 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 }}'", )