Backlog over time
Due clocks per stream, sampled every 5 minutes.
Liveness, throughput and the direction of the backlog — read together.
Due clocks per stream, sampled every 5 minutes.
Pool slots in use and background actors. Rate is clocks/min; if a cycle crawls without writing clocks, page pace from its log is shown too.
Click a stream to break it down by store. Pace is observations per hour against what the learned intervals need.
Store × stream cycles launched by the orchestrator pool.
Queue cycles, crawls, sweeps and browser sessions, then follow them as the workers pick them up.
Same commands as the CLI, through the worker queue.
Process the next due batch of one channel × stream.
Jobs and browser sessions, newest first. Click a row to follow it — the detail keeps your place while it updates.
| created | kind | target | status | duration | result |
|---|
The store × stream pool: what it runs now, what comes next, and what it has done. Freshness per store lives in the Overview.
Running slots first, then the waiting queue in the order the pool will claim it. Rate is clocks refreshed in the last minute; score = late share × average lateness × envelope priority.
Runs ecom orchestrate run on this host, under the same lease as the CLI.
PRODUCT + STOCK covers the normal portfolio. Use STOCK=2 to leave seats for PRODUCT. SHIPPING needs postal codes. Workers = 0 is legacy per-group mode.
One bar per cycle, coloured by stream. Failed cycles are red; click a bar to open its output.
What the pool did with each store × stream in the window.
History drain, projection, jobs, harvest and reviews — each with its last result.
The multiplier each envelope adds to the score, and how many active pairs use it. Edit in stores.yaml.
Newest first. Click a row for the cycle's output.
Where there are clocks, delays or ingestion gaps.
Expand a channel to compare clocks, envelope and last observation per stream.
Most recent observations the controller recorded for a domain × stream.
Manage what the cycle tracks and the priority of each page.
| page / variant | weight | PRODUCT | STOCK | expires |
|---|
Each row is a subscribed URL. Expand it to see variants and individual clocks.
Retires only what is past its term.
Adds what is missing and retires what left.
Deletes permanently after the given period.
Transport, streams, policy and discovery commands. Click a channel for portfolio health.
Read-only. Policy lives in stores.yaml; channel facts live in code. Health reads the final layer via offer-catalog-api.
Explore a domain before implementing it in the crawler. Add the store, run the pipeline, and see which stages already left artifacts. Nothing here is written into the catalog.
Explore, analyze, build and sweep jobs for this agent. Cancel stops a queued run immediately. A running browser stops within a few seconds. Click a row for the worker log.
| created | stage | domain | target | status | duration | result |
|---|
A filled chip means that stage already has artifacts. A plain chip has not run. Counts are categories found, listing pages saved, and product facts exported.
| domain | pipeline | found |
|---|
One collection, or smoke-test the first page.
Run a stage again any time. Explore opens a visible browser. If that page is HTTP 403, the run waits up to 3 minutes for someone to clear it and for the page to change.
Categories and brands from the last explore.
—
| name | url |
|---|
—
| name | url |
|---|
Listing pages and exported product facts on disk.
Capability map, ready-made commands and the interactive docs.
The UI uses the same routes and guards as the CLI. Use the interface day to day and copy commands when you need to automate or run workers.