-
Notifications
You must be signed in to change notification settings - Fork 16.4k
Remove direct scheduler BaseOperator refs #52234
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
Remove direct scheduler BaseOperator refs #52234
Conversation
3862cd8 to
d297979
Compare
2c48445 to
d51aeab
Compare
33883e1 to
77fee4c
Compare
kaxil
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.
Looks good on high-level but want to look at the s10n changes more closely.
cc @ashb @amoghrajesh - More eyes will help here.
9e1c268 to
14598c4
Compare
|
(rebased on main to get latest changes & running with full-tests now) |
airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
Outdated
Show resolved
Hide resolved
airflow-core/src/airflow/api_fastapi/core_api/services/ui/grid.py
Outdated
Show resolved
Hide resolved
|
I want to take a look at what the serialized Dag JSON looks like with this change too. |
6423b6b to
7f9c6f7
Compare
|
Serialised dag JSON does not change; this only removes the JSON → SerializedBaseOperator part; the SDK operator → JSON part is not affected. |
7f9c6f7 to
94cc204
Compare
5e3b5e4 to
1400861
Compare
1400861 to
4172002
Compare
They are either changed to SerializedBaseOperator or the SDK BaseOperator. If this works, we can work on combining the scheduler BaseOperator into SerializedBaseOperator, and remove SDK BaseOperator base references in the scheduler. Scheduler BaseOperator is now removed entirely since SerializedBaseOperator is all that's needed in the scheduler. Furthermore, SerializedBaseOperator no longer inherits from the SDK BaseOperator, so in the future we can separate the two inheritance tree entirely.
4172002 to
39ab2e9
Compare
They are either changed to SerializedBaseOperator or the SDK BaseOperator. If this works, we can work on combining the scheduler BaseOperator into SerializedBaseOperator, and remove SDK BaseOperator base references in the scheduler.