Fix alpha generation pipeline runnable-output blockers

alpha_factory/orchestration/pipeline.py

@@ -17,10 +17,10 @@ from ..deterministic.expression_mutator import generate_mutations
 from ..personas import (
     generate_hypothesis,
     compile_expression,
-    scout_novelty,
     diagnose_performance,
     gate_alpha,
 )
+from ..personas import crowd_scout
 from ..schemas import Verdict, BrainMetrics, Component, Neutralization, AnomalyTag
 from ..data.brain_groups import get_group_for_expression
 from ..local.brain_sim import simulate_alpha_local, sign_sweep_local
@@ -267,8 +267,12 @@ class AlphaPipeline:
             console.print(f"  [yellow]Warnings:[/] {lint_result.warnings}")
 
         # STEP 2: Dedup
+        # Keep a snapshot for the checklist. The live set is updated immediately
+        # so later candidates in the same batch still deduplicate correctly, but
+        # the current candidate must not fail its own checklist as a duplicate.
+        pre_existing_hashes = set(existing_hashes)
         alpha_id = quick_dedup_hash(expr, blueprint.neutralization.value, blueprint.decay)
-        if alpha_id in existing_hashes:
+        if alpha_id in pre_existing_hashes:
             console.print(f"  [red]DEDUP:[/] Already exists")
             return Verdict.KILL
         existing_hashes.add(alpha_id)
@@ -318,7 +322,7 @@ class AlphaPipeline:
             expression=expression,
             lint_result=lint_result,
             alpha_id=alpha_id,
-            existing_hashes=existing_hashes,
+            existing_hashes=pre_existing_hashes,
             existing_anomaly_tags=existing_tags,
             max_corr_to_library=max_corr,
             local_sim_sharpe=local_metrics.sharpe if local_metrics else 1.5,
@@ -333,7 +337,7 @@ class AlphaPipeline:
         console.print(f"  [green]CHECKLIST PASS[/]")
 
         # STEP 6: Crowd Scout — novelty check
-        crowd_result = await scout_novelty(
+        crowd_result = await crowd_scout.scout_novelty(
             self.llm, expr, blueprint.theme,
             blueprint.anomaly_tag.value, existing_tags, max_corr
         )
@@ -418,8 +422,14 @@ class AlphaPipeline:
 
         try:
             result = await self.brain.submit_alpha(expression, neutralization, decay)
-
-            if result.get("status") == "DONE":
+            status = str(result.get("status", "")).upper()
+            sim_id = result.get("id") or result.get("simulationId") or result.get("simulation_id")
+            if status in {"PENDING", "RUNNING", "SUBMITTED", "IN_PROGRESS"} and sim_id:
+                console.print(f"  [cyan]BRAIN POLL:[/] Simulation {sim_id} status={status}")
+                result = await self.brain.poll_simulation(str(sim_id))
+                status = str(result.get("status", "")).upper()
+
+            if status == "DONE":
                 self._daily_submissions += 1
                 metrics = self.brain.parse_metrics(result, alpha_id)
                 self.store.update_metrics(alpha_id, metrics, 0.0)