qa-async-jobs
Background job and queue testing: 8 skills (bullmq-tests, celery-tests, cron-job-test-author, idempotency-test-author, kafka-consumer-tests, rabbitmq-patterns, sidekiq-tests, sqs-patterns) and 1 agent (async-job-health-critic). Covers async job runners, queue patterns, scheduled jobs, and idempotency guarantees.
Install this plugin
/plugin install qa-async-jobs@testland-qaPart of role bundle: qa-role-backend
qa-async-jobs
Background job and queue testing. Five per-tool skill wrappers covering the mainstream OSS + AWS queue ecosystem (Sidekiq, Celery, BullMQ, SQS, RabbitMQ) plus two build-an-X workflow skills for cross-tool patterns (cron-job-test-author, idempotency-test-author).
Covers the production-defect cluster around at-least-once delivery, retry storms, dead-letter handling, missed cron executions, and idempotency.
Components
| Type | Name | Description |
|---|---|---|
| Agent | async-job-health-critic | Read-only adversarial critic: scans queue/worker code for missing retry limits, absent dead-letter routing, uncapped backoff, and missing idempotency guards across BullMQ/Celery/Sidekiq/SQS/RabbitMQ; emits findings + BLOCK/PASS verdict |
| Skill | sidekiq-tests | Sidekiq fake!/inline!/disable! test modes; RSpec + Minitest helpers; retry + scheduled-set + unique-jobs testing |
| Skill | celery-tests | pytest-celery fixtures (celery_app, celery_worker, celery_session_worker); apply() vs delay(); retry-mocking via patch() |
| Skill | bullmq-tests | Queue + Worker patterns; QueueEvents listeners; retry/backoff/repeat-job; FlowProducer parent-child |
| Skill | sqs-patterns | Standard vs FIFO semantics; visibility timeout; DLQ routing; mock (aws-sdk-client-mock / moto) vs LocalStack vs real SQS |
| Skill | rabbitmq-patterns | 6 canonical tutorial patterns (Hello World / Work Queues / Pub-Sub / Routing / Topics / RPC); Publisher Confirms; ack/nack/requeue; DLX |
| Skill | cron-job-test-author | Build-an-X for cron tests: expression validation, DST + leap-day edge cases, missed-execution detection, overlap protection, stale-lock recovery |
| Skill | idempotency-test-author | Build-an-X for idempotency tests: idempotency-key pattern (Stripe/AWS), commutative side effects, TTL tuning, concurrent-duplicate race tests |
| Skill | kafka-consumer-tests | Test Kafka consumers/producers: Testcontainers, offsets, rebalance, EOS/transactions, dead-letter topics. |
Install
/plugin marketplace add testland/qa
/plugin install qa-async-jobs@testland-qaSkills
bullmq-tests
Authors and runs BullMQ job tests in TypeScript / JavaScript - `Queue` and `Worker` patterns, processor mocking, retry/backoff/repeat-job assertions, FlowProducer for parent-child job dependencies, QueueEvents listeners; tests use a real Redis instance (Docker / Testcontainers / `ioredis-mock` for stricter unit-test isolation). Use when the user works with BullMQ in Node.js services and needs unit / integration tests for queue producers, worker processors, or flow orchestration.
celery-tests
Authors and runs Celery task tests in Python - `pytest-celery` fixtures (`celery_app`, `celery_worker` per-test, `celery_session_worker` per-session); `task_always_eager` config NOT recommended for unit tests; `apply()` for synchronous test invocation; mock-and-patch retry patterns via `unittest.mock.patch` on `task.retry`. Use when the user works with Celery task workers and needs unit / integration tests across function-style or class-style tasks.
cron-job-test-author
Build-an-X for cron / scheduler job tests - cron-expression validation patterns (5-field standard `min hour day-month month day-week` + 6-field with seconds + named-list extensions), DST + leap-day edge cases, missed-execution detection (machine downtime catch-up), overlapping-run protection (lock + stale-lock recovery), timezone semantics. Use when authoring tests for cron jobs, Kubernetes CronJobs, BullMQ repeat-jobs, Sidekiq schedulers, or any time-based job runner.
idempotency-test-author
Build-an-X for idempotency tests in any async/job/API context - idempotency-key handling (per Stripe / AWS prescriptive guidance pattern), retry-safe semantics (exactly-once vs at-least-once vs at-most-once), side-effect commutativity verification, fingerprint-based dedup, idempotency-window tuning. Use when authoring tests for any system where the same input could be processed twice (SQS Standard at-least-once, RabbitMQ requeue, retry-on-error logic, webhook redelivery, browser double-click, mobile-network retry).
kafka-consumer-tests
Tests Apache Kafka consumer and producer logic across KafkaJS (Node.js), kafka-go (Go), and Spring Kafka (Java) - spins up a real broker via the Testcontainers Kafka module, asserts offset management and consumer-group rebalance behavior, distinguishes at-least-once from exactly-once (EOS / transactions), validates idempotent producer configuration, and routes unprocessable messages to a dead-letter topic. Use when the user works with Kafka producers or consumers in any language and needs integration or unit tests that exercise delivery semantics, offset commits, rebalance handling, or dead-letter routing.
rabbitmq-patterns
Tests RabbitMQ producer/consumer interactions - supports AMQP 0.9.1 and AMQP 1.0 protocols across 6 tutorial patterns (Hello World, Work Queues, Publish/Subscribe, Routing, Topics, RPC) plus Publisher Confirms; consumer ack/nack/requeue patterns; durable queues + persistent messages; quorum vs classic queue; tests via Testcontainers RabbitMQ image or LocalStack-equivalent. Use when the user works with RabbitMQ producers/consumers (pika, amqplib, RabbitMQ.Client, spring-amqp) and needs unit/integration tests.
sidekiq-tests
Authors and runs Sidekiq job tests in Ruby - three Sidekiq::Testing modes (`fake!` jobs accumulate in arrays, `inline!` runs jobs immediately, `disable!` enqueues to Redis as normal); RSpec + Minitest helper patterns; clears jobs between tests via `Sidekiq::Worker.clear_all`; assertion patterns on `MyWorker.jobs.size` and `MyWorker.jobs.first[:args]`. Use when the user works with Sidekiq workers and needs unit / integration tests for job enqueueing, scheduling, retry behavior, or unique-job semantics.
sqs-patterns
Tests AWS SQS queue interactions - Standard (at-least-once delivery, near-unlimited throughput) vs FIFO (exactly-once processing, ordered) queue semantics; visibility-timeout interaction model; dead-letter queue (DLQ) for poison-message isolation; message retention period (default 4 days, configurable 60s - 1209600s); test patterns via LocalStack or `aws-sdk-client-mock` (TypeScript) / `moto` (Python). Use when the user works with AWS SQS producers/consumers and needs unit/integration tests for queue interactions.