kaxil commented on code in PR #71465:
URL: https://github.com/apache/airflow/pull/71465#discussion_r3765829451
##########
providers/anthropic/src/airflow/providers/anthropic/hooks/anthropic.py:
##########
@@ -694,15 +695,58 @@ def send_event(self, session_id: str, event: dict[str,
Any]) -> Any:
session_id, events=cast("list[BetaManagedAgentsEventParams]",
[event])
)
- def archive_session(self, session_id: str) -> BetaManagedAgentsSession:
+ def interrupt_session(self, session_id: str) -> Any:
Review Comment:
Kept public, deliberately. `archive_session` is the only in-tree caller
today, but the two have different time budgets: archiving retries for roughly
25s at the defaults, while a task's `on_kill` is SIGKILLed a few seconds in. A
caller that just wants to stop billable runtime and let the session settle has
a real use for the interrupt on its own.
It is also a thin wrapper over the already-public `send_event`, so making it
private would hide the name without removing the capability. Happy to flip it
if you would rather keep the surface minimal.
--
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]
