3tears-scheduled-jobs 0.23.8
“Generic, payload-agnostic, multipod-safe scheduled-jobs core -- cross-pod-locked tick engine, reschedule math, store protocols, and a defau…”
imports PackageNotFoundError from importlib.metadata as _PackageNotFoundErrorimports importlib.metadata
SHA-25654aed19d702b4dd490f5706f10cc94c1e628104da020d358d813f4bdc75b90ae
MaleculeO(As)H(Db₂)
Evidence
56:20… ict[str, Any] = {
57 "partition_key": UUID,
58 "job_id": UUID,
59 "kind": str,
60 "payload": dict,
61 "schedule_type": str,
62 "schedule_config": dict,
63 "status": str,
64 "next_fire_at": datetime | None,
65 "last_fired_at": datetime | None,
66 "missed_fire_policy": str,
67 "name": str …
159:29… "{c} = EXCLUDED.{c}" for c in update_cols)
160 return (
161 f"INSERT INTO {table} ({column_list}) VALUES ({placeholders}) "
162 f"ON CONFLICT ({pk_list}) DO UPDATE SET {set_clause}"
163 )
⋯4 lines
186:38… ion_key = $1 AND job_id = $2"
187)
188
189
190_SCHEDULED_JOBS_DELETE_SQL = "DELETE FROM scheduled_jobs WHERE partition_key = $1 AND job_id = $2"
191
192
193_JOB_FIRES_FETCH_SQL = (
194 "SELECT partition_key, fire_id, job_id, scheduled_fire_at, " …
602:57… state columns.
603 await self.l3_pool.execute(
604 "UPDATE job_fires SET status = $1, output = $2, latency_ms = $3 WHERE partition_key = $4 AND fire_id = $5",
605 status,
606 output,
607 …
698:34… atching' AND actual_fired_at < $2 "
699 "AND job_id IN (SELECT job_id FROM scheduled_jobs WHERE kind = ANY($3)) "
700 "RETURNING partition_key, fire_id",
701 REAPED_DISPATCH_ERROR,
702 cutoff,
No evidence locations were recorded for this file. Raw result