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