suiting-young commented on a change in pull request #14821:
URL: https://github.com/apache/airflow/pull/14821#discussion_r597367239
##########
File path: airflow/serialization/serialized_objects.py
##########
@@ -433,10 +433,12 @@ def deserialize_operator(cls, encoded_op: Dict[str, Any])
-> BaseOperator:
for ope in plugins_manager.operator_extra_links:
for operator in ope.operators:
- if (
+ if ((
operator.__name__ == encoded_op["_task_type"]
and operator.__module__ == encoded_op["_task_module"]
- ):
+ ) if not isinstance(operator, str) else (
Review comment:
Extracted this part to a function in
1fde244c350f302de52ddea92b850ba76f454fcc.
--
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.
For queries about this service, please contact Infrastructure at:
[email protected]
