This is an automated email from the ASF dual-hosted git repository.
amoghrajesh 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 4830882c6e1 Remove uneccessary json.dumps from example task store dag
(#68202)
4830882c6e1 is described below
commit 4830882c6e157185e51ca437e6d7ec7ae98bb5a7
Author: Amogh Desai <[email protected]>
AuthorDate: Mon Jun 8 14:49:58 2026 +0530
Remove uneccessary json.dumps from example task store dag (#68202)
---
airflow-core/src/airflow/example_dags/example_task_store.py | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/airflow-core/src/airflow/example_dags/example_task_store.py
b/airflow-core/src/airflow/example_dags/example_task_store.py
index b96bda00ca8..4192882a4bf 100644
--- a/airflow-core/src/airflow/example_dags/example_task_store.py
+++ b/airflow-core/src/airflow/example_dags/example_task_store.py
@@ -27,7 +27,6 @@ of submitting a duplicate.
from __future__ import annotations
-import json
import random
import string
import time
@@ -82,7 +81,7 @@ with DAG(
task_store.set("status", "running")
result = _poll_job(job_id)
task_store.set("status", "complete")
- task_store.set("result", json.dumps(result))
+ task_store.set("result", result)
print(f"Try {try_number}: job complete — {result['rows_written']} rows
written")
return result["rows_written"]
