Enable resilient tasks in LRA samples (invocations + responses) + responses 2.0.0b1 core floor bump

sdk/agentserver/azure-ai-agentserver-invocations/samples/resilient_langgraph/app.py

@@ -66,6 +66,7 @@
     EventStreamNotFoundError,
     streams,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 from azure.ai.agentserver.invocations import InvocationAgentServerHost
 
 try:
@@ -82,6 +83,12 @@
 
 app = InvocationAgentServerHost()
 
+# Opt into resilient-task startup recovery. This sample declares a durable
+# task, so the framework would enable recovery automatically; we set the switch
+# explicitly to make the intent clear and to keep recovery working even if the
+# task is ever registered lazily (after startup).
+set_resilient_tasks_enabled(True)
+
 
 async def _sse_from_stream(
     stream: EventStream, invocation_id: str, *, initial_status: str = "queued"

sdk/agentserver/azure-ai-agentserver-invocations/samples/resilient_multiturn/app.py

@@ -36,7 +36,7 @@
 from starlette.requests import Request
 from starlette.responses import JSONResponse, Response
 
-from azure.ai.agentserver.core.tasks import TaskConflictError
+from azure.ai.agentserver.core.tasks import TaskConflictError, set_resilient_tasks_enabled
 from azure.ai.agentserver.invocations import InvocationAgentServerHost
 
 try:
@@ -46,6 +46,12 @@
 
 app = InvocationAgentServerHost()
 
+# Opt into resilient-task startup recovery. This sample declares a durable
+# task, so the framework would enable recovery automatically; we set the switch
+# explicitly to make the intent clear and to keep recovery working even if the
+# task is ever registered lazily (after startup).
+set_resilient_tasks_enabled(True)
+
 
 @app.invoke_handler
 async def handle_invoke(request: Request) -> Response:

sdk/agentserver/azure-ai-agentserver-invocations/samples/resilient_research/app.py

@@ -77,6 +77,7 @@
     EventStreamNotFoundError,
     streams,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 from azure.ai.agentserver.invocations import InvocationAgentServerHost
 
 try:
@@ -101,6 +102,12 @@
 
 app = InvocationAgentServerHost()
 
+# Opt into resilient-task startup recovery. This sample declares a durable
+# task, so the framework would enable recovery automatically; we set the switch
+# explicitly to make the intent clear and to keep recovery working even if the
+# task is ever registered lazily (after startup).
+set_resilient_tasks_enabled(True)
+
 
 # --- SSE rendering ---------------------------------------------------------
 

sdk/agentserver/azure-ai-agentserver-responses/samples/sample_19_resilient_streaming.py

@@ -62,10 +62,17 @@
     ResponsesAgentServerHost,
     ResponsesServerOptions,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 
 options = ResponsesServerOptions(resilient_background=True)
 app = ResponsesAgentServerHost(options=options)
 
+# Explicitly opt into resilient-task startup recovery, for parity with the
+# invocations resilient samples. The Responses framework already registers its
+# internal durable tasks at host construction (so recovery runs regardless);
+# this call just makes the opt-in intent explicit.
+set_resilient_tasks_enabled(True)
+
 _SIMULATE_SHUTDOWN_MS = int(os.environ.get("SIMULATE_SHUTDOWN_MS", "0"))
 
 # Phases run in order. Each emits one message output item and is made

sdk/agentserver/azure-ai-agentserver-responses/samples/sample_20_resilient_steering.py

@@ -66,13 +66,20 @@
     ResponsesAgentServerHost,
     ResponsesServerOptions,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 
 options = ResponsesServerOptions(
     resilient_background=True,
     steerable_conversations=True,
 )
 app = ResponsesAgentServerHost(options=options)
 
+# Explicitly opt into resilient-task startup recovery, for parity with the
+# invocations resilient samples. The Responses framework already registers its
+# internal durable tasks at host construction (so recovery runs regardless);
+# this call just makes the opt-in intent explicit.
+set_resilient_tasks_enabled(True)
+
 _SIMULATE_SHUTDOWN_MS = int(os.environ.get("SIMULATE_SHUTDOWN_MS", "0"))
 
 

sdk/agentserver/azure-ai-agentserver-responses/samples/sample_21_resilient_langgraph.py

@@ -77,6 +77,7 @@
     ResponsesAgentServerHost,
     ResponsesServerOptions,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 
 
 # ─── Graph state ────────────────────────────────────────────────────────────
@@ -198,6 +199,12 @@ async def _get_graph() -> Any:
 )
 app = ResponsesAgentServerHost(options=options)
 
+# Explicitly opt into resilient-task startup recovery, for parity with the
+# invocations resilient samples. The Responses framework already registers its
+# internal durable tasks at host construction (so recovery runs regardless);
+# this call just makes the opt-in intent explicit.
+set_resilient_tasks_enabled(True)
+
 # Metadata key: the LangGraph checkpoint id whose completed work matches the
 # response items persisted so far. Recorded in ``internal_metadata`` (persisted
 # atomically WITH the items on every ``stream.checkpoint()``, stripped on

sdk/agentserver/azure-ai-agentserver-responses/samples/sample_22_resilient_multiturn.py

@@ -44,13 +44,20 @@
     ResponsesServerOptions,
     TextResponse,
 )
+from azure.ai.agentserver.core.tasks import set_resilient_tasks_enabled
 
 options = ResponsesServerOptions(
     resilient_background=True,
     steerable_conversations=False,
 )
 app = ResponsesAgentServerHost(options=options)
 
+# Explicitly opt into resilient-task startup recovery, for parity with the
+# invocations resilient samples. The Responses framework already registers its
+# internal durable tasks at host construction (so recovery runs regardless);
+# this call just makes the opt-in intent explicit.
+set_resilient_tasks_enabled(True)
+
 
 @app.response_handler
 async def handler(