jscheffl commented on code in PR #38650:
URL: https://github.com/apache/airflow/pull/38650#discussion_r1546075083
##########
airflow/operators/python.py:
##########
@@ -243,13 +243,14 @@ def execute(self, context: Context) -> Any:
def determine_kwargs(self, context: Mapping[str, Any]) -> Mapping[str,
Any]:
return KeywordParameters.determine(self.python_callable, self.op_args,
context).unpacking()
- def execute_callable(self) -> Any:
+ def execute_callable(self, dataset_events: DatasetEventAccessors) -> Any:
Review Comment:
Mhm, it is not exactly defined as "public" but at least we have also a
custom subclass of python operator developed in our environment. So everybody
having a subclass of this will see a breaking change?
--
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]
