Prab-27 commented on code in PR #66694:
URL: https://github.com/apache/airflow/pull/66694#discussion_r3460096673
##########
task-sdk/src/airflow/sdk/execution_time/task_runner.py:
##########
@@ -2085,7 +2085,7 @@ def main():
log = structlog.get_logger(logger_name="task")
global SUPERVISOR_COMMS
- SUPERVISOR_COMMS = CommsDecoder[ToTask, ToSupervisor](log=log)
+ SUPERVISOR_COMMS = CommsDecoder[ToTask, ToSupervisor]()
Review Comment:
Yes I also confused for this - now got it ! Thanks @kaxil !
I have checked on my side that the issue requirements are satisfied
Would you like me to give any other tasks to do in this or I'll close this
PR and will close this `issue as completed `
Would love to hear your thoughts @uranusjr !
--
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]
