JH-A-Kim commented on code in PR #68106:
URL: https://github.com/apache/airflow/pull/68106#discussion_r3384699271
##########
task-sdk/src/airflow/sdk/execution_time/supervisor.py:
##########
@@ -1678,221 +1606,63 @@ def final_state(self):
return TaskInstanceState.FAILED
def _handle_request(self, msg: ToSupervisor, log: FilteringBoundLogger,
req_id: int):
- if isinstance(msg, MaskSecret):
- log.debug("Received message from task runner (body omitted)",
msg=type(msg))
- else:
- log.debug("Received message from task runner", msg=msg)
Review Comment:
Added it back in commit b303d9e2fad4a46cc399f777d0fd04c22405565a
Thanks you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
