idZddlmZddlZddlmZddlmZddlmZeje Z eGddZ Gd d Z y) u~ core/merge/swarm_result.py SwarmResult — data model for a single worker's output in a parallel swarm run. SwarmConflictDetector — identifies when 2+ workers produce contradictory outputs for the same session. Note: This module is Track A of the AIVA RLM Nexus PRD v2. The name ``SwarmConflictDetector`` is intentionally distinct from ``ConflictDetector`` in core/merge/conflict_detector.py (Track B), which operates on RFC 6902 StateDelta patches. This class operates on SwarmResult output dicts instead. # VERIFICATION_STAMP # Story: 6.01 # Verified By: parallel-builder # Verified At: 2026-02-25 # Tests: 29/29 # Coverage: 100% ) annotationsN) dataclass)datetime)AnycDeZdZUdZded<ded<ded<ded<d ed <y ) SwarmResultu Represents the output produced by a single swarm worker for a given session. Attributes: session_id: Identifier of the conversation/session this result belongs to. worker_name: Name/ID of the worker that produced the result. output: Free-form dict of key→value pairs produced by the worker. completed_at: UTC timestamp when the worker finished. confidence: Confidence score in [0.0, 1.0] for the result. str session_id worker_namedictoutputr completed_atfloat confidenceN)__name__ __module__ __qualname____doc____annotations__0/mnt/e/genesis-system/core/merge/swarm_result.pyrr%s% O LrrcBeZdZdZddZddZe ddZy) SwarmConflictDetectora Identifies when 2+ SwarmResult objects for the same session contain contradictory output values. Conflict definition ------------------- Two results conflict when they share the same session_id AND have at least one common output key whose values are: - both non-None, AND - not equal to each other. Keys present in only one result, or where either value is None, are considered complementary and NOT conflicts. c6t|j|S)a Return True if 2+ results for the same session have conflicting outputs. A conflict requires: - Same ``session_id`` - Same output key - Both values non-None - Values are not equal Args: results: List of SwarmResult objects (may span multiple sessions). Returns: True if at least one conflict exists, False otherwise. )bool get_conflicts)selfresultss rdetectzSwarmConflictDetector.detectRs D&&w/00rct|dkrgSg}i}|D]-}|j|jgj|/|j D]g\}}t|dkrt t|D]<}t |dzt|D]}||} ||} |j | | |!>itjdt|t||S)u" Return all conflicting (result_a, result_b, conflicting_key) tuples. For every pair of results sharing the same session_id, each output key that appears in both with differing non-None values yields one tuple. Each conflicting key generates exactly one tuple per conflicting pair. Args: results: List of SwarmResult objects to inspect. Returns: List of (SwarmResult, SwarmResult, str) tuples — one per conflict. Empty list when no conflicts exist. u@SwarmConflictDetector.get_conflicts: %d results → %d conflicts) len setdefaultr appenditemsrange_find_pair_conflictsloggerdebug) rr conflicts by_sessionrr session_resultsijresult_aresult_bs rrz#SwarmConflictDetector.get_conflictsds  wA  ! !!,, 3 : :1 = >,6+;+;+= M 'J?#a'3/0 Mq1uc/&:;MA.q1H.q1H--h)LM M M  N L  N rc|j}|j}|j|jz}t|D]+}||}||}||||k7s|j|||f-y)z Append (result_a, result_b, key) to *conflicts* for every key that is present in both outputs with differing non-None values. Mutates *conflicts* in place. N)r keyssortedr&) r2r3r,output_aoutput_b shared_keyskeyval_aval_bs rr)z*SwarmConflictDetector._find_pair_conflictss$,??#+??mmo 7 +& list[tuple])r2rr3rr,r?r>None)rrrrr r staticmethodr)rrrrr>sJ &1$*`<<<<  <rGsR*#!   8 $  0r<r