-
Notifications
You must be signed in to change notification settings - Fork 16.4k
AIP-69: Add Executor to Edge Provider #42048
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
AIP-69: Add Executor to Edge Provider #42048
Conversation
45b7e33 to
dc70939
Compare
dc70939 to
57775d3
Compare
0fd2bbf to
dad57cd
Compare
27da6c0 to
7338f09
Compare
7338f09 to
7eb06d6
Compare
providers/src/airflow/providers/edge/executors/edge_executor.py
Outdated
Show resolved
Hide resolved
ashb
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Pre-emptively approving, but please either address https://github.com/apache/airflow/pull/42048/files#r1805240595 or tell me why it's not a problem.
(cherry picked from commit 4e9c2262f567a2511d02d4acd43b821fa0df45d2)
7eb06d6 to
87a4188
Compare
Can confirm both: Addressed it and it is not a problem! |
* Add Executor to Edge Provider * Review feeedback + small adjustments from Niko * Add explicit note about non-performance in current state * Fix adoption of tasks when restarting scheduler (cherry picked from commit 4e9c2262f567a2511d02d4acd43b821fa0df45d2) * Optimize sync call for MVP executor * Adjust new folder structure from PR 42505 * Review feedback: removed cleanup_stuck_queued_tasks() and added notes about performance tests
* Add Executor to Edge Provider * Review feeedback + small adjustments from Niko * Add explicit note about non-performance in current state * Fix adoption of tasks when restarting scheduler (cherry picked from commit 4e9c2262f567a2511d02d4acd43b821fa0df45d2) * Optimize sync call for MVP executor * Adjust new folder structure from PR 42505 * Review feedback: removed cleanup_stuck_queued_tasks() and added notes about performance tests
* Add Executor to Edge Provider * Review feeedback + small adjustments from Niko * Add explicit note about non-performance in current state * Fix adoption of tasks when restarting scheduler (cherry picked from commit 4e9c2262f567a2511d02d4acd43b821fa0df45d2) * Optimize sync call for MVP executor * Adjust new folder structure from PR 42505 * Review feedback: removed cleanup_stuck_queued_tasks() and added notes about performance tests
This PR is a split of #41729 and builds on-top of #42046 and #42047 to make review easier.
It only contains the new Edge Executor functions needed of the edge provider package. The first commit is from the other base PRs and if this is merged will go-away on rebase. If you want to see Executor implementation only, please take a look to the second commit only,