Conversation
Adds a standalone stress test script that enqueues a configurable number of tasks across multiple queues and processes them through the full supervisor with multiple workers and threads. Verifies invariants like no lost jobs, no duplicate executions, and no stuck executions — the kind of issues reported in #25 and #26. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
Runs the stress test with 10 tasks as a separate job in parallel with the test matrix, just to verify the harness doesn't break. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
The cleanup step deletes from steady_queue tables which don't exist yet on a fresh CI database. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
The steady_queue tables live on the queue database, not the default one. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
tests/stress_test.py) that spins up the full supervisor with configurable workers/threads/queues, enqueues thousands of tasks, and verifies correctness invariants (no lost jobs, no duplicates, no stuck executions).stress_counter_taskto the dummy test app with configurable workload profiles (--workload none|light|medium|heavy) mixing IO-bound (sleep) and CPU-bound (SHA-256 iterations) work.django.taskslogger in test settings to reduce noise during stress runs.This is the kind of test that surfaces race conditions like #25 (duplicate
ClaimedExecution) and #26 (processisNoneon execution).Usage
Test plan
🤖 Generated with Claude Code