Module worker_loop 

The loop both credit registration workers run.

The processes differ only in which phases they own and how often they look, so the scheduling lives here instead of in each of them.

Constants

STILL_RUNNING_MESSAGE_TICKS 🔒

Ten minutes of ticks. The per-phase heartbeat in the database is the machine-readable half.

TICK_INTERVAL_SECS 🔒

How often the loop looks for a due phase; each phase’s own interval lives in credit_registration_phase_state.

Functions

is_due 🔒

A phase is due when an admin asked for it, or when its interval has elapsed since it last began.

log_failure 🔒

phase_states 🔒

Every phase’s state in one read, so a tick costs one query rather than one per owned phase.

run

Runs the phases this process owns until it is stopped, matching process_name against CreditRegistrationPhase::process_name.

run_due_phase 🔒

Runs one due phase, and schedules the next run.