Module schedule 

Redis-backed scheduled-job store and due-sweep for the Pub/Sub backend.

Deferred and retrying jobs live in a per-queue Redis sorted set {key_prefix}:pubsub:scheduled:{queue_name} (member = serialized [ScheduledJob], score = target run time in Unix seconds). A due-sweep atomically claims due members (so one fleet instance publishes each) and publishes them to the queue’s topic — the apalis store-and-run-when-due pattern. The topic therefore only ever carries already-due jobs.