Fix: Worker polling set to 1h and heartbeat silenced to prevent DB bloating (Phase 9)

backend/worker.py

@@ -7,6 +7,7 @@ import uuid
 from services.task_queue import TaskQueueService
 from services.supabase_service import supabase
 from services.agent_runner_service import AgentRunnerService
+from services.budget_service import BudgetExceededError
 from services.config import settings
 
 logging.basicConfig(level=logging.INFO)
@@ -87,6 +88,11 @@ class AubmWorker:
                             logger.info("Task %s completed successfully.", task_id)
                         else:
                             raise RuntimeError(f"Assigned agent not found: {agent_id}")
+                    except BudgetExceededError as e:
+                        logger.warning("Budget blocked queued task %s: %s", task_id, e)
+                        self.failed_count += 1
+                        await TaskQueueService.mark_failed(task_id, str(e))
+                        await self.heartbeat("error")
                     except Exception as e:
                         logger.error("Failed to process task %s: %s", task_id, e)
                         self.failed_count += 1
@@ -96,10 +102,10 @@ class AubmWorker:
                             self.max_attempts,
                             self.retry_delay_seconds,
                         )
-                        await self.heartbeat("error")
                 else:
-                    # No tasks, sleep for a bit (10s)
-                    await asyncio.sleep(10)
+                    # No tasks, sleep for an hour as requested (3600s)
+                    # This prevents filling the DB with poll/heartbeat logs
+                    await asyncio.sleep(3600)
         finally:
             if heartbeat_task:
                 heartbeat_task.cancel()