amoghrajesh commented on code in PR #60799:
URL: https://github.com/apache/airflow/pull/60799#discussion_r2706821087
##########
airflow-core/src/airflow/serialization/serialized_objects.py:
##########
@@ -1060,11 +1062,11 @@ def _serialize_node(cls, op: SdkOperator) -> dict[str,
Any]:
if attr in serialize_op:
del serialize_op[attr]
- # Detect if there's a change in python callable name
+ # Store python_callable_name for change detection.
+ # exclude_module=True ensures stable names across bundle version
changes.
python_callable = getattr(op, "python_callable", None)
if python_callable:
- callable_name = qualname(python_callable)
- serialize_op["python_callable_name"] = callable_name
+ serialize_op["python_callable_name"] = qualname(python_callable,
exclude_module=True)
Review Comment:
Was just reviewing in consideration to collision between tasks but since its
scoped deep in the nested structure, we are good
--
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]
