JobSpec

Defined in dccd.application.jobs

class JobSpec(*, id, operation, target, trigger, params=JobParams(start='last', depth=None, snapshot_interval=None, derive_from=None, transport=None), enabled=True, origin='config')[source]

Bases: BaseModel

Declarative job definition.

A histo job is: backfill + interval trigger (+ start=”last”). A stream job is: stream + supervised trigger.