Claude Code: Add verbose startup logging for asyncio task debugging

- Add detailed logging in startup_event to prove handler ran
- Wrap asyncio.create_task in try/except to catch failures
- Add log before while True loop to verify task entry
- Add iteration logging in polling loop
- Reduce sleep to 1s for faster feedback

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

app.py

@@ -87,9 +87,17 @@ async def _poll_a2a_ready_state():
     Background polling task to detect RUNNING_A2A_READY state and trigger agent execution.
     This bridges the synchronization deadlock where the worker ignores push events.
     """
+    # 3. Hard loop check - log BEFORE entering while loop
+    logger.info("=" * 60)
+    logger.info("[POLLING TASK] ========== _poll_a2a_ready_state() ENTERED ==========")
+    logger.info(f"[POLLING TASK] Timestamp: {datetime.utcnow().isoformat()}")
+    logger.info("[POLLING TASK] About to enter while True loop...")
+    logger.info("=" * 60)
+
     data_dir = Path(os.environ.get("OPENCLAW_DATA_DIR", "/data"))
     status_file = data_dir / "cain_status.json"
 
+    iteration = 0
     while True:
         try:
             # Read current status
@@ -114,12 +122,14 @@ async def _poll_a2a_ready_state():
                     except Exception as e:
                         logger.warning(f"[A2A Polling] Failed to trigger agent: {e}")
 
-            # Wait 5 seconds before next poll
-            await asyncio.sleep(5)
+            # 4. Timeout safety - sleep with iteration logging
+            iteration += 1
+            logger.info(f"[POLLING TASK] Iteration {iteration} complete, sleeping 1s...")
+            await asyncio.sleep(1)  # Reduced to 1s for faster feedback
 
         except Exception as e:
             logger.warning(f"[A2A Polling] Error in polling loop: {e}")
-            await asyncio.sleep(5)
+            await asyncio.sleep(1)
 
 
 @app.on_event("startup")
@@ -127,6 +137,13 @@ async def startup_event():
     """Start background worker thread and A2A polling task on app startup."""
     global _worker_thread, _worker_stop_event, _polling_task
 
+    # 1. Verbose startup logging - prove handler ran
+    logger.info("=" * 60)
+    logger.info("[STARTUP] ========== STARTUP EVENT HANDLER TRIGGERED ==========")
+    logger.info(f"[STARTUP] Timestamp: {datetime.utcnow().isoformat()}")
+    logger.info(f"[STARTUP] PID: {os.getpid()}")
+    logger.info("=" * 60)
+
     # Check WORKER_MODE before starting worker
     worker_mode = os.environ.get("WORKER_MODE", "auto").lower()
     if worker_mode == "disabled":
@@ -138,8 +155,18 @@ async def startup_event():
         _worker_thread.start()
         logger.info(f"[Cain] Worker thread started: {_worker_thread.name}")
 
-    logger.info("[Cain] Starting A2A ready state polling task...")
-    _polling_task = asyncio.create_task(_poll_a2a_ready_state())
+    # 2. Wrap task creation in try/except
+    logger.info("[STARTUP] About to create asyncio task for A2A polling...")
+    try:
+        _polling_task = asyncio.create_task(_poll_a2a_ready_state())
+        logger.info(f"[STARTUP] SUCCESS: asyncio.create_task() returned task object: {_polling_task}")
+        logger.info(f"[STARTUP] Task done? {_polling_task.done()}")
+        logger.info(f"[STARTUP] Task cancelled? {_polling_task.cancelled()}")
+    except Exception as e:
+        logger.error(f"[STARTUP] FAILED: asyncio.create_task() raised exception: {e}")
+        import traceback
+        traceback.print_exc()
+        _polling_task = None
 
 
 @app.on_event("shutdown")