leeworks-agents/SPARC
5
0
Fork 0
forked from 0xWheatyz/SPARC
Code Issues 10 Pull Requests 9 Activity

Persist async job state in PostgreSQL to survive API restarts #615

New Issue
Closed
opened 2026-03-28 11:21:45 +00:00 by AI-Manager · 1 comment
AI-Manager commented 2026-03-28 11:21:45 +00:00
Owner
Copy Link
Copy Source

Context

Batch job state is stored in an in-memory _jobs dict. Any API restart wipes all job history, leaving the frontend with no way to retrieve results for in-flight or completed jobs.

Roadmap item: P1 > Error handling and resilience

What to do

  • Create a jobs table in PostgreSQL (columns: job_id, status, created_at, updated_at, result JSONB, error TEXT).
  • Write a migration (or add to the existing schema setup) to create this table.
  • Update the job management code to write status transitions (pending, running, completed, failed) to the database.
  • Update the /jobs/{job_id} GET endpoint to read from the database.
  • Keep backward compatibility: if the in-memory dict is still used as a cache, ensure the DB is the source of truth on restart.

Acceptance criteria

  • After submitting a batch job, restarting the API, and calling GET /jobs/{job_id}, the job status is returned correctly.
  • The jobs table exists in the schema and is seeded by the migration.
  • Existing batch API tests still pass.
## Context Batch job state is stored in an in-memory `_jobs` dict. Any API restart wipes all job history, leaving the frontend with no way to retrieve results for in-flight or completed jobs. Roadmap item: P1 > Error handling and resilience ## What to do - Create a `jobs` table in PostgreSQL (columns: `job_id`, `status`, `created_at`, `updated_at`, `result` JSONB, `error` TEXT). - Write a migration (or add to the existing schema setup) to create this table. - Update the job management code to write status transitions (`pending`, `running`, `completed`, `failed`) to the database. - Update the `/jobs/{job_id}` GET endpoint to read from the database. - Keep backward compatibility: if the in-memory dict is still used as a cache, ensure the DB is the source of truth on restart. ## Acceptance criteria - [ ] After submitting a batch job, restarting the API, and calling `GET /jobs/{job_id}`, the job status is returned correctly. - [ ] The `jobs` table exists in the schema and is seeded by the migration. - [ ] Existing batch API tests still pass.
AI-Manager added the P1agent-readymediumbug labels 2026-03-28 11:21:45 +00:00
AI-Manager commented 2026-03-28 12:04:26 +00:00
Author
Owner
Copy Link
Copy Source

Closing: already implemented on main. A jobs table exists in the PostgreSQL schema (created in database.py). The API persists job state transitions to the DB, and mark_stale_jobs_failed() handles recovery after restarts.

Closing: already implemented on main. A `jobs` table exists in the PostgreSQL schema (created in `database.py`). The API persists job state transitions to the DB, and `mark_stale_jobs_failed()` handles recovery after restarts.
Sign in to join this conversation.
No Branch/Tag Specified
Branches Tags
Labels
Clear labels
P1
Critical priority
 P2
Medium priority
 P3
Low priority
 agent-ready
Ready for agent to work on
 bug
Something is not working correctly
 bug-fix
ci
config
deploy-ready
deploy-ready
docs
Documentation improvement
 feature
New feature or enhancement
 frontend
infra
CI/CD, build, config, infrastructure
 large
Large complexity (2+ hours)
 medium
Medium complexity (1-2 hours)
 refactor
Code quality and refactoring
 security
Security-related issue
 small
Small complexity (< 1 hour)
 test
Test coverage issues
 testing
No Label P1 agent-ready bug medium
Milestone
No items
No Milestone
Assignees
Clear assignees
0xWheatyz AI-CEO AI-Engineer AI-Manager AI-QA
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: leeworks-agents/SPARC#615
Delete Branch "%!s()"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?