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 }}'", )