fix: sha256:58981a2606ddc4f96980b255b0f771d2a0f9f6f4786cebb0edb4e6640d3beea5 · gabriel/musehub

fix(RC-3/phase2): per-mpack_key dedup for mpack.index + dedup_payload_key on enqueue_job

enqueue_push_intel now partitions jobs into coarse (all except mpack.index) and index buckets. Coarse types share one SELECT IN for dedup as before. Each mpack.index job is deduped per payload['mpack_key'] via a JSONB WHERE clause, so two pushes with distinct mpack keys each produce their own index row instead of the second being silently dropped.

Empty mpack_key falls back to coarse dedup, preserving legacy/no-key callers (MIE-4, B4). compute_job_id receives "mpack.index:<key>" as the job_type arg to prevent primary-key collision when two distinct keys arrive at the same timestamp.

enqueue_job gains an optional dedup_payload_key kwarg that scopes the idempotency check and job_id generation to a specific payload value.

Tests: MWP3_07 (distinct keys → two rows), MWP3_08 (same key → one row), MWP3_08b × 3 (enqueue_job dedup_payload_key variants), MWP3_09 (coarse types unaffected). All 12 MWP3 tests + B1-B4 + MIE1-5 + FMC_18 pass.

symbols added

symbols modified

dead code introduced

Semantic Changes 8 symbols

~ musehub/services/musehub_jobs.py .py 2 symbols modified

~ enqueue_job

~ enqueue_push_intel

~ tests/test_mwp3_job_idempotency.py .py 6 symbols added

+ test_mwp3_07_distinct_mpack_keys_both_produce_index_jobs function async_function test_mwp3_07_distinct_mpack_keys_both_produce_index_jobs L490–535

+ test_mwp3_08_same_mpack_key_deduped_to_one_row function async_function test_mwp3_08_same_mpack_key_deduped_to_one_row L544–579

+ test_mwp3_08b_default_coarse_behavior_unchanged function async_function test_mwp3_08b_default_coarse_behavior_unchanged L680–713

+ test_mwp3_08b_distinct_payload_key_produces_two_rows function async_function test_mwp3_08b_distinct_payload_key_produces_two_rows L588–635

+ test_mwp3_08b_same_payload_key_deduped_to_one_row function async_function test_mwp3_08b_same_payload_key_deduped_to_one_row L639–676

+ test_mwp3_09_coarse_types_remain_deduplicated function async_function test_mwp3_09_coarse_types_remain_deduplicated L722–766

Older docs(mwp-3): mark Phase 1 complete sha256:02049dee4f4f70ab4944a79812441c4bf3fce1b74ba3388676c6b640693037f3 All commits Newer docs: mark phase 2 complete in mwp-3-job-idempotency issue sha256:6fbda1f15f21a8aa22c57ee274c2da52681987b73ca07f651e1c73b5caea9bf5

0 comments

No comments yet. Be the first to start the discussion.

To add a comment, use the Muse CLI: muse hub commit comment sha256:58981a2606ddc4f96980b255b0f771d2a0f9f6f4786cebb0edb4e6640d3beea5 --body "your comment"