(airflow) branch main updated: Adding tojson filter to example_inlet_event_extra example dag (#41873)

[potiuk]

This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 87a4a51375 Adding tojson filter to example_inlet_event_extra example 
dag (#41873)
87a4a51375 is described below

commit 87a4a5137519448cfff85fc506b9267ec3e18364
Author: Amogh Desai <amoghrajesh1...@gmail.com>
AuthorDate: Fri Aug 30 18:14:25 2024 +0530

    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 471a215532..4b7567fc2f 100644
--- a/airflow/example_dags/example_inlet_event_extra.py
+++ b/airflow/example_dags/example_inlet_event_extra.py
@@ -57,5 +57,5 @@ with DAG(
     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 }}'",
     )