forked from 0xWheatyz/SPARC
Move webhook delivery to background task queue #1690
Open
AI-Manager
wants to merge 1 commits from
feature/webhook-task-queue into main
pull from: feature/webhook-task-queue
merge into: leeworks-agents:main
leeworks-agents:main
leeworks-agents:feature/multi-tenant-isolation
leeworks-agents:feature/historical-analysis-diff
leeworks-agents:feature/1686-rate-limit-dashboard
leeworks-agents:feature/1684-cursor-pagination
leeworks-agents:feature/patent-classification-tags
leeworks-agents:feature/1674-batch-export-zip
leeworks-agents:feature/1685-stricter-company-name-validation
leeworks-agents:feature/api-key-auth
leeworks-agents:feature/1675-rate-limit-admin
leeworks-agents:feature/1669-cursor-pagination
leeworks-agents:feature/1670-company-name-validation
leeworks-agents:feature/1678-update-roadmap
leeworks-agents:feature/1656-tracked-company-admin-tests
leeworks-agents:feature/1661-analyze-single-patent-tests
leeworks-agents:feature/1660-s3-storage-tests
leeworks-agents:feature/1659-update-roadmap
leeworks-agents:feature/1658-scheduler-pooled-db
leeworks-agents:feature/1657-webhook-integration-tests
leeworks-agents:feature/1655-export-endpoint-tests
leeworks-agents:feature/1605-dark-mode
leeworks-agents:feature/1624-jwt-auth-tests
leeworks-agents:feature/1559-1560-enable-ci-linting-and-tests
leeworks-agents:feature/docs-patent-volume-mount
leeworks-agents:feature/1324-dark-mode-variants
leeworks-agents:feature/1013-multi-model
leeworks-agents:feature/426-generate-ts-api-client
leeworks-agents:feature/351-frontend-model-picker
leeworks-agents:feature/343-batch-loading-states
leeworks-agents:feature/env-example-updates
leeworks-agents:feature/260-tsc-ci
leeworks-agents:feature/export-pdf
leeworks-agents:feature/multi-model
leeworks-agents:feature/openapi-client-gen
leeworks-agents:feature/trend-charts
leeworks-agents:feature/compare-view
leeworks-agents:feature/s3-storage
leeworks-agents:feature/webhooks
leeworks-agents:feature/scheduled-analysis
leeworks-agents:feature/export-csv
leeworks-agents:feature/cursor-pagination
leeworks-agents:feature/dark-mode
leeworks-agents:feature/loading-error-states
leeworks-agents:feature/fix-single-patent-download
leeworks-agents:feature/structured-logging
leeworks-agents:feature/ci-tsc-lint
leeworks-agents:feature/ci-testing-linting
leeworks-agents:feature/db-client-pooling
leeworks-agents:feature/p2-config-improvements
leeworks-agents:feature/jwt-auth-tests
leeworks-agents:feature/persist-job-state
leeworks-agents:feature/p2-docs-and-lockfile
leeworks-agents:feature/rate-limiting
leeworks-agents:feature/p1-security-hardening
leeworks-agents:chore/add-roadmap
1 Commits
| Author | SHA1 | Message | Date | |
|---|---|---|---|---|
|
|
ab3964b18d |
Move webhook delivery to background task queue
Introduce a lightweight in-process task queue (thread + queue.Queue) so that webhook HTTP delivery no longer blocks the scheduler or batch-job background tasks. The worker thread preserves the existing exponential- backoff retry logic from _send_with_retry. - Add SPARC/task_queue.py: WebhookTask, start/stop worker, enqueue, drain - Add enqueue_notify / enqueue_job_completed / enqueue_alert to webhooks.py - Update api.py lifespan to start/stop the webhook worker - Update _run_batch_job to use enqueue_job_completed (non-blocking) - Update scheduler to fire enqueue_alert on patent count changes - Add 13 tests covering worker lifecycle, async delivery, retry in worker context, and integration via enqueue helpers - All 22 existing webhook tests continue to pass unchanged Closes leeworks-agents/SPARC#1676 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com> |