kaxil commented on code in PR #69243:
URL: https://github.com/apache/airflow/pull/69243#discussion_r3518343403
##########
airflow-core/tests/unit/serialization/test_serialized_objects.py:
##########
@@ -1309,6 +1309,59 @@ def
test_has_retry_policy_flag_false_when_no_policy(self):
task = deserialized.task_dict["op_no_policy"]
assert task.has_retry_policy is False
+ def test_mapped_task_retry_policy_serializes_as_flag(self):
+ """A mapped task's retry_policy must serialize as has_retry_policy,
not the object."""
+ import json
Review Comment:
Thanks. One leftover from the same sweep: the `from
airflow.sdk.definitions.retry_policy import ExceptionRetryPolicy, RetryAction,
RetryRule` copies (four across this class now) have no module-level counterpart
and no name collision, so they can be hoisted to the top of the module as well.
--
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]
