ferruzzi commented on code in PR #62645:
URL: https://github.com/apache/airflow/pull/62645#discussion_r3066412212
##########
providers/edge3/src/airflow/providers/edge3/cli/worker.py:
##########
@@ -229,7 +229,7 @@ def _run_job_via_supervisor(self, workload: ExecuteTask,
results_queue: Queue) -
try:
supervise(
# This is the "wrong" ti type, but it duck types the same.
TODO: Create a protocol for this.
- # Same like in
airflow/executors/local_executor.py:_execute_work()
+ # Same like in
airflow/executors/local_executor.py:_execute_workload()
Review Comment:
I still feel like is the exact time to be using a deprecation warning and
edge will be updated by @wjddn279 in PR
https://github.com/apache/airflow/pull/63498. All executors will need to be
updated, and that work is organized here
https://github.com/apache/airflow/issues/62887
--
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]
