Repository navigation
feat(oie): RQ A→B→C fan-out and Admin OIE queue tab - #1142
Open
northdpole wants to merge 15 commits into
Open
northdpole wants to merge 15 commits into
northdpole wants to merge 15 commits into
Conversation
northdpole
requested review from
Pa04rth,
paoga87 and
robvanderveer
as code owners
October 9, 2026 08:37
Contributor
|
Important Review skippedAuto reviews are disabled on base/target branches other than the default branch. 🗂️ Base branches to auto review: 1
Please check the settings in the CodeRabbit UI or the ⚙️ Run configuration
You can disable this status message by setting the Use the checkbox below for a quick retry:
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. Comment |
northdpole
force-pushed
the
admin-panel-showcase
branch
from
October 11, 2026 23:04
e114292 to
4178ecf
Compare
northdpole
force-pushed
the
feat/oie-rq-fanout
branch
from
October 11, 2026 23:05
723d697 to
cba71ba
Compare
4 tasks
northdpole
force-pushed
the
admin-panel-showcase
branch
from
October 12, 2026 07:05
4178ecf to
aad929a
Compare
northdpole
force-pushed
the
feat/oie-rq-fanout
branch
from
October 12, 2026 07:05
cba71ba to
2a1c75d
Compare
northdpole
force-pushed
the
admin-panel-showcase
branch
from
October 12, 2026 07:17
aad929a to
475945f
Compare
northdpole
force-pushed
the
feat/oie-rq-fanout
branch
from
October 12, 2026 07:17
2a1c75d to
545522b
Compare
northdpole
force-pushed
the
admin-panel-showcase
branch
from
October 12, 2026 07:19
475945f to
48e9d4f
Compare
northdpole
force-pushed
the
feat/oie-rq-fanout
branch
2 times, most recently
from
October 12, 2026 20:28
555b8fe to
d68ddbc
Compare
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.
northdpole
force-pushed
the
feat/oie-rq-fanout
branch
from
October 12, 2026 22:19
d68ddbc to
7aac2f5
Compare
northdpole
force-pushed
the
admin-panel-showcase
branch
from
October 12, 2026 22:19
48e9d4f to
30a2a40
Compare
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>
4 tasks
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.
This branch has not been deployed
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
oiefan-out for Module A (per repo) → B/C (perartifact_id), with--rq/CRE_OIE_RQ,start_oie_workers, andharvest_input.artifact_idmigration.oiequeue.repos_yamlTypeError 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.TestOieB2HarvesterLanggraphKwargsmake alembic-guardrail(new revisiona9b0c1d2e3f4)make start-oie-workers+scripts/run_oie_pipeline.py --rq(or full_pipeline--rq) drains queue without silent B2 TypeError/admin/oie/rq/statuswith queue depthStacked on #1137 (
admin-panel-showcase).Made with Cursor