Implement reproducer agent

.gitignore

@@ -54,8 +54,10 @@ ymir/agents/tests/e2e/mock_repos/*
 !ymir/agents/tests/e2e/mock_repos/README.md
 !ymir/agents/tests/e2e/mock_repos/triage/
 !ymir/agents/tests/e2e/mock_repos/backport/
+!ymir/agents/tests/e2e/mock_repos/reproducer/
 ymir/agents/tests/e2e/mock_repos/triage/*
 ymir/agents/tests/e2e/mock_repos/backport/*
+ymir/agents/tests/e2e/mock_repos/reproducer/*
 
 # E2E test output artifacts
 ymir/agents/tests/e2e/test_output/

AGENTS.md

@@ -101,6 +101,8 @@ For detailed deployment info: see [openshift/README.md](openshift/README.md)
 | Update OpenShift | `openshift/overlays/{dev,staging,prod}/` |
 | Add skill | `agents_as_skills/{skill_name}/SKILL.md` |
 | Change queue routing | [jira_label_workflow_routing.md](jira_label_workflow_routing.md) |
+| Reproducer design | [docs/reproducer_architecture.md](docs/reproducer_architecture.md) |
+| MR consolidation design | [docs/mr_consolidation_architecture.md](docs/mr_consolidation_architecture.md) |
 
 ## Documentation to Understand Workflows
 
@@ -110,6 +112,8 @@ For detailed deployment info: see [openshift/README.md](openshift/README.md)
 - **[brew_konflux_data_flow.md](brew_konflux_data_flow.md)** — Build system integration
 - **[ai_providers_data_flow.md](ai_providers_data_flow.md)** — Vertex AI integration
 - **[monitoring.md](monitoring.md)** — Observability and performance review
+- **[docs/reproducer_architecture.md](docs/reproducer_architecture.md)** — Reproducer agent, cross-stream reuse, create/adapt lock
+- **[docs/mr_consolidation_architecture.md](docs/mr_consolidation_architecture.md)** — MR consolidation agent and Redis queue
 
 ## Code Changes Checklist
 

Containerfile.c10s

@@ -75,7 +75,7 @@ RUN pip3 install --no-cache-dir \
       beeai-framework[vertexai,mcp,duckduckgo]==0.1.82 \
       "mcp<1.29.0" \
       google-cloud-aiplatform \
-      openinference-instrumentation-beeai \
+      openinference-instrumentation-beeai==0.1.21 \
       arize-phoenix-otel \
       redis \
       specfile \

Containerfile.c9s

@@ -78,7 +78,7 @@ RUN python3.11 -m venv --system-site-packages /opt/beeai-venv \
          beeai-framework[vertexai,mcp,duckduckgo]==0.1.82 \
          "mcp<1.29.0" \
          google-cloud-aiplatform \
-         openinference-instrumentation-beeai \
+         openinference-instrumentation-beeai==0.1.21 \
          arize-phoenix-otel \
          redis \
          specfile \

Containerfile.c9s-tests

@@ -28,7 +28,7 @@ RUN python3.11 -m venv --system-site-packages /opt/beeai-venv \
        "litellm!=1.82.7,!=1.82.8" \
        beeai-framework[vertexai,mcp,duckduckgo]==0.1.82 \
        "mcp<1.29.0" \
-       openinference-instrumentation-beeai \
+       openinference-instrumentation-beeai==0.1.21 \
        arize-phoenix-otel \
        aiohttp>=3.12.15 \
        redis \

Containerfile.supervisor

@@ -30,7 +30,7 @@ RUN dnf -y install --allowerasing \
       beeai-framework[vertexai,mcp,duckduckgo]==0.1.82 \
       "mcp<1.29.0" \
       google-cloud-aiplatform \
-      openinference-instrumentation-beeai \
+      openinference-instrumentation-beeai==0.1.21 \
       arize-phoenix-otel \
       redis \
       specfile \

Makefile

@@ -84,6 +84,23 @@ run-backport-agent-e2e-tests:
 		backport-agent-e2e-tests
 
 
+.PHONY: run-reproducer-agent-e2e-tests
+run-reproducer-agent-e2e-tests:
+	$(COMPOSE) -f $(COMPOSE_FILE) --profile=e2e-test run --rm \
+		-e MOCK_JIRA="true" \
+		-e DRY_RUN="true" \
+		-e TESTING_FARM_DRY_RUN="false" \
+		reproducer-agent-e2e-tests
+
+.PHONY: run-reproducer-agent-standalone
+run-reproducer-agent-standalone:
+	$(COMPOSE_AGENTS) run --rm \
+		-e JIRA_ISSUE=$(JIRA_ISSUE) \
+		-e DRY_RUN=$(DRY_RUN) \
+		-e MOCK_JIRA=$(MOCK_JIRA) \
+		-e JIRA_DRY_RUN=$(JIRA_DRY_RUN) \
+		reproducer-agent
+
 .PHONY: run-rebase-agent-c9s-standalone
 run-rebase-agent-c9s-standalone:
 	$(COMPOSE_AGENTS) run --rm \
@@ -322,6 +339,44 @@ trigger-pipeline:
 	@echo "Triggering pipeline for issue: $(JIRA_ISSUE) (force_cve_triage=$(FORCE_CVE_TRIAGE))"
 	$(COMPOSE_AGENTS) exec valkey redis-cli LPUSH triage_queue '{"metadata": {"issue": "$(JIRA_ISSUE)", "force_cve_triage": $(FORCE_CVE_TRIAGE)}}'
 
+# Manually enqueue a reproducer job (triage auto-enqueue is currently disabled).
+# Required: JIRA_ISSUE, PACKAGE
+# Optional: CVE_ID, FIX_VERSION, TARGET_BRANCH, TRIAGE_SUMMARY, USER_TRIGGERED=true
+.PHONY: trigger-reproducer
+trigger-reproducer:
+	@if [ -z "$(JIRA_ISSUE)" ] || [ -z "$(PACKAGE)" ]; then \
+		echo "Usage: make trigger-reproducer JIRA_ISSUE=RHEL-12345 PACKAGE=bind \\"; \
+		echo "         [CVE_ID=CVE-2025-12345] [FIX_VERSION=rhel-10.1] [TARGET_BRANCH=c10s] \\"; \
+		echo "         [TRIAGE_SUMMARY='…'] [USER_TRIGGERED=true]"; \
+		exit 1; \
+	fi
+	@echo "Enqueueing reproducer for $(JIRA_ISSUE) (package=$(PACKAGE), user_triggered=$(or $(USER_TRIGGERED),false))"
+	@payload=$$( \
+		JIRA_ISSUE="$(JIRA_ISSUE)" \
+		PACKAGE="$(PACKAGE)" \
+		CVE_ID="$(CVE_ID)" \
+		FIX_VERSION="$(FIX_VERSION)" \
+		TARGET_BRANCH="$(TARGET_BRANCH)" \
+		TRIAGE_SUMMARY="$(TRIAGE_SUMMARY)" \
+		USER_TRIGGERED="$(or $(USER_TRIGGERED),false)" \
+		python3 -c 'import json, os; \
+meta = {"jira_issue": os.environ["JIRA_ISSUE"], "package": os.environ["PACKAGE"]}; \
+[meta.__setitem__(k, v) for k, e in ( \
+    ("cve_id", "CVE_ID"), \
+    ("fix_version", "FIX_VERSION"), \
+    ("target_branch", "TARGET_BRANCH"), \
+    ("triage_summary", "TRIAGE_SUMMARY"), \
+) if (v := (os.environ.get(e) or "").strip())]; \
+print(json.dumps({ \
+    "metadata": meta, \
+    "attempts": 0, \
+    "user_triggered": os.environ.get("USER_TRIGGERED", "false").lower() == "true", \
+}))' \
+	) && \
+	queue=$$(if [ "$(or $(USER_TRIGGERED),false)" = "true" ]; then echo reproducer_queue_todo; else echo reproducer_queue; fi) && \
+	$(COMPOSE_AGENTS) exec -T valkey redis-cli LPUSH $$queue "$$payload" && \
+	echo "Pushed to $$queue"
+
 
 # Testing and Release Supervisor
 

README-agents.md

@@ -116,8 +116,15 @@ make trigger-pipeline JIRA_ISSUE=RHEL-12345
 
 # Force triage of Y-stream CVEs (normally skipped)
 make trigger-pipeline JIRA_ISSUE=RHEL-12345 FORCE_CVE_TRIAGE=true
+
+# Manually enqueue a reproducer job (triage auto-enqueue is currently disabled)
+make trigger-reproducer JIRA_ISSUE=RHEL-12345 PACKAGE=bind
+make trigger-reproducer JIRA_ISSUE=RHEL-12345 PACKAGE=bind CVE_ID=CVE-2025-12345 FIX_VERSION=rhel-10.1
 ```
 
+See [docs/reproducer_architecture.md](docs/reproducer_architecture.md#manual-queue-submit)
+for full `trigger-reproducer` options.
+
 **Environment variables:**
 | Variable | Default | Description |
 |----------|---------|-------------|

README.md

@@ -73,6 +73,7 @@ For installation instructions (skill setup and MCP tool configuration), see the
 - [AI Providers Data Flow](ai_providers_data_flow.md) - Google Vertex AI integration and model usage
 - [Agent Monitoring and Performance Review](monitoring.md) - Monitoring processes, anomaly detection, and continuous improvement
 - [MR Consolidation Architecture](docs/mr_consolidation_architecture.md) - Merging multiple backport MRs into a single MR
+- [Reproducer Architecture](docs/reproducer_architecture.md) - Automated test reproducers, cross-stream reuse, and create/adapt locking
 
 **Data management:**