Skip to content

Worker Runtime Modules

Central controller

  • backend/src/cpi/worker.py Main controller for background loops, per-tenant iteration, lock handling, queue dispatch, and follow-up task checks.

Main loop families

Loop Config key Runtime key Typical responsibility
archive jobs.archive.config jobs.archive.runtime archive older data on a planned time
packages jobs.iflows.config jobs.iflows.runtime package and iFlow inventory refresh
payloads jobs.payloads.config jobs.payloads.runtime fetch payloads after package dependency is satisfied
messages hot jobs.messages.config last_run_hot fast-moving recent message sync
messages cold jobs.messages.config last_run_cold slower cold-range message sync
alerts jobs.alerts.config jobs.alerts.runtime evaluate alert definitions against stored runtime data
stats worker job plus cache cache entries refresh aggregate tenant statistics

Shared runtime concepts

  • set_lock and release_lock
  • job_run_create_queued
  • job_run_mark_*
  • runtime timestamps such as last_run, last_run_hot, last_run_cold, last_seen_completed

Important dependencies

  • payloads wait for package completion
  • messages wait for package completion
  • alerts wait for package completion
  • edge-reference mode can make iFlow sync a mandatory dependency