From f10f5525c833e261a88f6caad763804a043bba39 Mon Sep 17 00:00:00 2001
From: Amogh Desai <amoghrajesh1999@gmail.com>
Date: Fri, 20 Dec 2024 17:52:29 +0530
Subject: [PATCH] AIP-72: Logging task runner messages in supervisor (#45108)

---
 task_sdk/src/airflow/sdk/execution_time/supervisor.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/task_sdk/src/airflow/sdk/execution_time/supervisor.py b/task_sdk/src/airflow/sdk/execution_time/supervisor.py
index 4d021656f8448..73bc446a28df8 100644
--- a/task_sdk/src/airflow/sdk/execution_time/supervisor.py
+++ b/task_sdk/src/airflow/sdk/execution_time/supervisor.py
@@ -709,6 +709,7 @@ def handle_requests(self, log: FilteringBoundLogger) -> Generator[None, bytes, N
             self._handle_request(msg, log)
 
     def _handle_request(self, msg: ToSupervisor, log: FilteringBoundLogger):
+        log.debug("Received message from task runner", msg=msg)
         resp = None
         if isinstance(msg, TaskState):
             self._terminal_state = msg.state