ashb commented on a change in pull request #19965:
URL: https://github.com/apache/airflow/pull/19965#discussion_r771580120
##########
File path: airflow/models/baseoperator.py
##########
@@ -196,16 +216,37 @@ def apply_defaults(self, *args: Any, **kwargs: Any) ->
Any:
self._BaseOperator__instantiated = True
return result
+ apply_defaults.__non_optional_args = non_optional_args # type: ignore
+ apply_defaults.__param_names = set(non_varaidc_params.keys()) # type:
ignore
+
return cast(T, apply_defaults)
def __new__(cls, name, bases, namespace, **kwargs):
new_cls = super().__new__(cls, name, bases, namespace, **kwargs)
+ try:
+ # Update the partial descriptor with the class method so it call
call the actual function (but let
+ # subclasses override it if they need to)
+ partial_desc = vars(new_cls)['partial']
Review comment:
Yeah, this is very much deep stuff that I hope no one ever has to touch
again :)
--
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]
