Skip to content

feat(oie): RQ A→B→C fan-out and Admin OIE queue tab - #1142

Open
northdpole wants to merge 17 commits into
admin-panel-showcasefrom
feat/oie-rq-fanout
Open

northdpole wants to merge 17 commits into
admin-panel-showcasefrom
feat/oie-rq-fanout

Conversation

@northdpole

Copy link
Copy Markdown
Collaborator

Summary

  • Add RQ queue oie fan-out for Module A (per repo) → B/C (per artifact_id), with --rq / CRE_OIE_RQ, start_oie_workers, and harvest_input.artifact_id migration.
  • Admin OIE queue tab + shared RQ dashboard snapshot; wire import-all / workers for the oie queue.
  • Fix B2 eval harvester LangGraph repos_yaml TypeError so top10/llm/api score arms can run; keep promoted librarian/safety knobs usable on RQ workers.

Test plan

  • python -m unittest application.tests.oie_rq.fanout_test application.tests.oie_rq.stage_filter_test application.tests.oie_b2_gold_loader_test.TestOieB2HarvesterLanggraphKwargs
  • make alembic-guardrail (new revision a9b0c1d2e3f4)
  • Local: make start-oie-workers + scripts/run_oie_pipeline.py --rq (or full_pipeline --rq) drains queue without silent B2 TypeError
  • Admin OIE tab loads /admin/oie/rq/status with queue depth

Stacked on #1137 (admin-panel-showcase).

Made with Cursor

@coderabbitai

coderabbitai Bot commented Oct 9, 2026 •

Copy link
Copy Markdown
Contributor

Important

Review skipped

Auto reviews are disabled on base/target branches other than the default branch.

🗂️ Base branches to auto review: 1
  • main

Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration
  • Configuration used: Repository: OWASP/OpenCRE/.coderabbit.yml
  • Review profile: CHILL
  • Plan: Advanced
  • Run ID: f716ca97-5a3a-4c88-868d-5f34252a637c

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

  • 🔍 Trigger review
  • Autofix · Keep fixing CodeRabbit findings and required CI, and resolving merge conflicts

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

Comment @coderabbitai help to get the list of available commands.

northdpole and others added 13 commits October 14, 2026 09:39
Parallelize Module A/B/C on queue `oie` (artifact_id migration, workers,
CLI --rq), fix B2 harvester LangGraph repos_yaml TypeError, and keep
promoted librarian/safety knobs available to RQ workers.
Lowercase project tables, tighten refuse/fail-closed routing, and add a laptop demo runbook so synth stays above 90% with Nest sync.
Add LOGIN_ALLOWED_EMAILS so only Spyros/Rob/Rock can establish sessions on internet-facing staging.
Record staging.opencre.org tunnel/DNS layout and LOGIN_ALLOWED_EMAILS env for the three OWASP operators.
Ship deploy/staging with own Postgres/Redis/web/worker, skip-sync entrypoint knobs, and pathspec so the image boots behind the Cloudflare tunnel.
Workers, Admin ingest, and the full-pipeline harness now share
apply_promoted_defaults() (pgvector, margin γ=0.85, judge, safety, leaf
drilldown). Staging Compose inherits the same knobs; image builds can
pull requirements-dev for C.2.
Mint/verify keys for allowlisted operators, audit log + migrations, and
stop caching SPA bundles so admin deploys pick up new JS.
Move shortlist/edition/neighbor/safety caches into Postgres, keep edition
remap live-LLM off by default, batch safety checks, and gate C.1/C.2 for
ablation. Includes accuracy-lever modules, staging compose tweaks, and
admin upstream-sync+ingest helpers.
When both fail-closed levers are on, Module C issues a single combined judge
call instead of two. Stop oie.env from overwriting worker DEV_DATABASE_URL so
parallel accuracy-matrix scoring hits cre_al_wN instead of empty cre.
Keep edition-remap live LLM off, safety batching on, and experimental
fail-closed levers off unless an eval explicitly enables them.
Lets operators recover stalled Module C work via /admin/oie/rq without docker or redis CLI.
Ship sidebar shell, needs-attention/review-pulse dashboard, paginated
staged-link review with title/content, workbench targets, and
GET /admin/config/diff — all still gated by login + CRE_ALLOW_IMPORT.
Staging monitors need API-key access to /admin/oie and related ops routes; also resolve CRE links by uuid or external_id and align ingest test asserts with skip_c1/max_repos=0.

Co-authored-by: Cursor <cursoragent@cursor.com>
Operators can see per-run start flags, live HI/KQ/RQ remaining, ETA, and stuck detection on the Pipeline tab (and a strip on Overview).
Remaining/ETA now track KQ+RQ only and use snap-to-snap drain rate so old ImportRuns stop inventing multi-day estimates.
Main landed MCP v2 (f3a91c07d24b) on 967016ee10fa; keep a single Alembic
head by parenting the stack's oie_run revision after mcp_grants.
login_or_mcp_required now accepts allowlisted API JWTs as well as
session/MCP identity, and API keys carry ALL_SCOPES for require_scopes.

This branch has not been deployed

No deployments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant