This is an automated email from the ASF dual-hosted git repository.
weilee pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 7f7c7a7b459 Fix comment typo in PythonOperator (#47558)
7f7c7a7b459 is described below
commit 7f7c7a7b4594fe753dcfa106e2c14228e8d09793
Author: Tzu-ping Chung <[email protected]>
AuthorDate: Mon Mar 10 20:47:32 2025 +0800
Fix comment typo in PythonOperator (#47558)
---
.../standard/src/airflow/providers/standard/operators/python.py | 8 +++-----
1 file changed, 3 insertions(+), 5 deletions(-)
diff --git
a/providers/standard/src/airflow/providers/standard/operators/python.py
b/providers/standard/src/airflow/providers/standard/operators/python.py
index 9b67511cf4e..d5fa639ad6f 100644
--- a/providers/standard/src/airflow/providers/standard/operators/python.py
+++ b/providers/standard/src/airflow/providers/standard/operators/python.py
@@ -212,13 +212,11 @@ class PythonOperator(BaseOperator):
"""
try:
from airflow.utils.operator_helpers import ExecutionCallableRunner
-
- asset_events = self._asset_events if AIRFLOW_V_3_0_PLUS else
self._dataset_events
-
- runner = ExecutionCallableRunner(self.python_callable,
asset_events, logger=self.log)
except ImportError:
- # Handle Pre Airflow 3.10 case where ExecutionCallableRunner was
not available
+ # Handle Pre Airflow 2.10 case where ExecutionCallableRunner was
not available
return self.python_callable(*self.op_args, **self.op_kwargs)
+ asset_events = self._asset_events if AIRFLOW_V_3_0_PLUS else
self._dataset_events
+ runner = ExecutionCallableRunner(self.python_callable, asset_events,
logger=self.log)
return runner.run(*self.op_args, **self.op_kwargs)
