ashb opened a new pull request, #44874:
URL: https://github.com/apache/airflow/pull/44874
The changes introduced here lets these existing classes serve "double" duty
in
the execution time of TaskSDK and also the Parse Time in the DAG Processor
(but the actual switch to use these will be a separate bigger PR).
There are a few warts left here, namely:
- The default on `CommsDecoder`'s decoder argument is incorrect for
subclasses, we might fix that later to be more dynamic about the default.
- The location of this code is not right for reuse in TaskSDK/execution time
and parse time. There is a bigger bit of work being planned to move this
all
around before release of Airflow 3
- Some of the functions on the base `WatchedSubprocess` class are TI specific
and maybe should be on a separate subclass
--
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]
