Scheduler

Defined in dccd.application.scheduler

class Scheduler(registry, store, runs_store=None, events=None)

Bases: object

Orchestrates JobSpecs (intervals → backfill; supervised → streams).

Parameters:

registrySourceRegistry

storeParquetStore

runs_storeRunsStore or None

eventsEventBus

register_streams(specs)

Register stream workers from config without starting them.

Called by the app lifespan so stream jobs appear in /api/streams and can be started/stopped from the UI even in dccd ui mode.

async run_now(spec)

Trigger a one-shot backfill for spec immediately.

async start(specs)

Start all enabled specs (full daemon mode).

async stop()

Stop all running jobs.