Add Snipsync markers to AgentCore Worker

Author: lennessyy

bedrock_agentcore/strands-agent/agentcore_worker.py

@@ -47,6 +47,7 @@ def required_env(key: str) -> str:
 DEPLOYMENT_NAME = os.environ.get("TEMPORAL_DEPLOYMENT_NAME", workflows.DEPLOYMENT_NAME)
 BUILD_ID = os.environ.get("TEMPORAL_BUILD_ID", workflows.BUILD_ID)
 
+# @@@SNIPSTART python-agentcore-activity-tracker
 # How long the Worker keeps polling after it goes idle.
 DEBOUNCE = float(os.environ.get("AGENTCORE_DEBOUNCE_SECONDS", "60"))
 # How long the drain waits for in-flight Activities (a model or tool call).
@@ -94,8 +95,10 @@ async def execute_activity(self, input: ExecuteActivityInput):
         finally:
             self._tracker.inflight -= 1
             self._tracker.changed.set()
+# @@@SNIPEND
 
 
+# @@@SNIPSTART python-agentcore-runtime-handler
 @app.entrypoint
 @app.async_task  # keeps /ping on "HealthyBusy" until this returns
 async def invoke(payload: dict) -> dict:
@@ -135,6 +138,7 @@ async def invoke(payload: dict) -> dict:
             await tracker.wait_until_idle(DEBOUNCE)
     log.info("worker idle for %ss; drained", DEBOUNCE)
     return {"message": "worker drained", "task_queue": task_queue}
+# @@@SNIPEND
 
 
 if __name__ == "__main__":