From efd12c2863bf0e15616e34623eeea8e3c7832498 Mon Sep 17 00:00:00 2001 From: Amogh Desai Date: Mon, 8 Jun 2026 11:49:36 +0530 Subject: [PATCH] Remove uneccessary json.dumps from example task store dag --- 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 b96bda00ca889..4192882a4bf33 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 @@ from __future__ import annotations -import json import random import string import time @@ -82,7 +81,7 @@ def run_job(**context): 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"]