kaxil commented on code in PR #69379:
URL: https://github.com/apache/airflow/pull/69379#discussion_r3531047154
##########
providers/anthropic/src/airflow/providers/anthropic/hooks/anthropic.py:
##########
@@ -149,6 +150,29 @@ def evaluate_session_state(
return False, None, False
+#: Statuses the provider's triggers emit in their terminal event.
+TRIGGER_EVENT_STATUSES = frozenset({"success", "error", "timeout"})
+
+
+def validate_execute_complete_event(event: dict[str, Any] | None = None) ->
dict[str, Any]:
+ """
+ Validate the event a deferred task resumes with, returning it if
well-formed.
+
+ The event crosses the triggerer/worker boundary through the metadata DB,
so a
+ resuming task can receive ``None`` or a status its handlers do not
recognise
Review Comment:
```suggestion
resuming task can receive ``None`` or a status its handlers do not
recognize
```
to fix
https://github.com/apache/airflow/actions/runs/28707554278/job/85426653320?pr=69379
--
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]
