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 🔒

How often each phase’s loop looks whether it is due; each phase’s own interval lives in credit_registration_phase_state.

Statics

LAST_LOGGED_SKIP 🔒

The skip reason last logged for a phase, so a paused phase or an open breaker logs once per state change instead of on every tick until it clears.

Functions

cancel_on_termination_signal 🔒

Kubernetes sends SIGTERM and waits terminationGracePeriodSeconds before killing the pod.

clear_skip_state 🔒

is_due 🔒

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

log_failure 🔒

log_skip_if_changed 🔒

run

Runs the phases process owns until SIGTERM or Ctrl-C. Each phase loops on its own, so an hour-long call in one does not hold up the others. On shutdown no phase starts another iteration, and the function returns once the iterations already running have finished.

run_due_phase 🔒

Runs one due phase, and schedules the next run.

run_if_due 🔒

run_phase_loop 🔒