Adding tojson filter to example_inlet_event_extra example dag (#41873) (#41890)

potiuk · amoghrajesh · utkarsharma2 · commit 09ec2616568f · 2024-09-02T17:09:40.000+05:30
(cherry picked from commit 87a4a51) Co-authored-by: Amogh Desai <amoghrajesh1999@gmail.com>
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 }}'",
     )

Original file line number	Diff line number	Diff line change
`@@ -57,5 +57,5 @@ def read_dataset_event(*, inlet_events=None):`
`57`	`57`	`BashOperator(`
`58`	`58`	`task_id="read_dataset_event_from_classic",`
`59`	`59`	`inlets=[ds],`
`60`		`- bash_command="echo {{ inlet_events['s3://output/1.txt'][-1].extra }}",`
	`60`	`+ bash_command="echo '{{ inlet_events['s3://output/1.txt'][-1].extra \| tojson }}'",`
`61`	`61`	`)`