> python verify.py
test_lost_response_retries_same_id_with_one_business_effect (test_queue.HttpTests.test_lost_response_retries_same_id_with_one_business_effect) ... ok
test_operator_api_auth_and_event_acceptance (test_queue.HttpTests.test_operator_api_auth_and_event_acceptance) ... ok
test_redirect_is_not_followed (test_queue.HttpTests.test_redirect_is_not_followed) ... ok
test_timeout_completes_attempt_as_retry (test_queue.HttpTests.test_timeout_completes_attempt_as_retry) ... ok
test_valid_signature_and_invalid_signature (test_queue.HttpTests.test_valid_signature_and_invalid_signature) ... ok
test_credentials_fragment_and_http_are_rejected (test_queue.PolicyTests.test_credentials_fragment_and_http_are_rejected) ... ok
test_defaults_deny_all_destinations (test_queue.PolicyTests.test_defaults_deny_all_destinations) ... ok
test_dns_mixed_public_private_is_rejected (test_queue.PolicyTests.test_dns_mixed_public_private_is_rejected) ... ok
test_global_address_is_returned_for_pinned_connection (test_queue.PolicyTests.test_global_address_is_returned_for_pinned_connection) ... ok
test_ipv6_mapped_and_linklocal_are_rejected (test_queue.PolicyTests.test_ipv6_mapped_and_linklocal_are_rejected) ... ok
test_test_exception_is_exact_origin (test_queue.PolicyTests.test_test_exception_is_exact_origin) ... ok
test_accept_is_atomic_across_destinations (test_queue.QueueTests.test_accept_is_atomic_across_destinations) ... ok
test_bad_payloads_are_rejected (test_queue.QueueTests.test_bad_payloads_are_rejected) ... ok
test_bounded_backoff_and_dead_letter (test_queue.QueueTests.test_bounded_backoff_and_dead_letter) ... ok
test_concurrent_claims_have_one_owner (test_queue.QueueTests.test_concurrent_claims_have_one_owner) ... ok
test_crash_budget_is_bounded (test_queue.QueueTests.test_crash_budget_is_bounded) ... ok
test_expired_owner_cannot_finish_without_replacement (test_queue.QueueTests.test_expired_owner_cannot_finish_without_replacement) ... ok
test_identical_retry_and_conflicting_id (test_queue.QueueTests.test_identical_retry_and_conflicting_id) ... ok
test_paused_endpoint_and_resume (test_queue.QueueTests.test_paused_endpoint_and_resume) ... ok
test_permanent_rejection_does_not_retry (test_queue.QueueTests.test_permanent_rejection_does_not_retry) ... ok
test_redirect_is_terminal (test_queue.QueueTests.test_redirect_is_terminal) ... ok
test_replay_keeps_event_id_and_attempt_history (test_queue.QueueTests.test_replay_keeps_event_id_and_attempt_history) ... ok
test_restart_preserves_committed_event (test_queue.QueueTests.test_restart_preserves_committed_event) ... ok
test_retention_preserves_pending_and_rejects_expired_replay (test_queue.QueueTests.test_retention_preserves_pending_and_rejects_expired_replay) ... ok
test_signing_secret_is_absent_from_snapshot_and_audit (test_queue.QueueTests.test_signing_secret_is_absent_from_snapshot_and_audit) ... ok
test_slow_endpoint_capacity_does_not_block_other_endpoint (test_queue.QueueTests.test_slow_endpoint_capacity_does_not_block_other_endpoint) ... ok
test_worker_crash_expires_and_fences_stale_completion (test_queue.QueueTests.test_worker_crash_expires_and_fences_stale_completion) ... ok
test_demo_setup_and_repeat_start (test_queue.StartupTests.test_demo_setup_and_repeat_start) ... ok

----------------------------------------------------------------------
Ran 28 tests in 3.420s

OK

{"command": "python verify.py", "tests": 28, "passed": 28, "failures": 0, "errors": 0, "skipped": 0, "success": true, "elapsed_seconds": 3.42, "python": "3.12.14"}


> python demo.py
{
  "fixture": "synthetic pump inspection events; fresh local HTTP receiver",
  "events": 13,
  "jobs": 37,
  "workers": 3,
  "per_endpoint_inflight": 1,
  "counts": {
    "dead": 1,
    "delivered": 36
  },
  "attempts": 49,
  "elapsed_seconds": 1.75,
  "outcomes": {
    "delivered": 36,
    "dead": 1,
    "retry": 12
  },
  "receivers": {
    "normal": {
      "requests": 12,
      "business_effects": 12
    },
    "response-loss": {
      "requests": 24,
      "business_effects": 12
    },
    "slow": {
      "requests": 12,
      "business_effects": 12
    }
  },
  "assertions": {
    "all_jobs_terminal": true,
    "response_loss_retried": true,
    "receiver_effects_deduplicated": true,
    "permanent_rejection_dead_lettered": true
  },
  "measurement_note": "Elapsed time includes fixture shutdown; this small local scenario is not a throughput benchmark."
}


> python operations_rehearsal.py
PASS crash.reclaim: Claim survives abrupt exit and a new worker replaces the expired owner
PASS crash.fence: Old worker completion rejected; replacement completion accepted
PASS http.delivery: Four workers deliver all 80 accepted jobs
PASS http.deduplication: 120 requests cause exactly 80 receiver business effects
PASS http.attempts: Attempt history contains the expected first failures and successful retries
PASS api.authorization: Missing administrator token is rejected
PASS api.boundary: Foreign Host and Origin requests are rejected
PASS api.storage: Storage failure returns retryable HTTP 503 without accepting an event
PASS restore.at-least-once: Restoring an older queue snapshot redelivers without duplicate receiver effect
PASS restore.identity: Restored acceptance still recognizes the same event identity
PASS restore.corruption: Corrupt snapshot rejected before destination creation
PASS restore.no-overwrite: Existing restore directory remains untouched
PASS integrity.final: Queue integrity and foreign-key checks pass
PASS theory.retry-budget: Declared four-attempt timeout/backoff calculation totals 15 seconds
PASS backup.schedule: Finite scheduler creates two checked snapshots and stops
{"checks": 15, "passed": 15, "elapsed_seconds": 1.795}


