This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v2-10-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v2-10-test by this push:
new e43d8fa491 Adding tojson filter to example_inlet_event_extra example
dag (#41873) (#41890)
e43d8fa491 is described below
commit e43d8fa4915d15d8a2b4f58fd7404fdb3b32131a
Author: Jarek Potiuk <[email protected]>
AuthorDate: Fri Aug 30 14:49:01 2024 +0200
Adding tojson filter to example_inlet_event_extra example dag (#41873)
(#41890)
(cherry picked from commit 87a4a5137519448cfff85fc506b9267ec3e18364)
Co-authored-by: Amogh Desai <[email protected]>
---
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 }}'",
)
