Benign python Download

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

Evidence

JSON result or response field key lines 56–67
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 …
Builds SQL with Python f-string interpolation lines 159–167
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
SQL DELETE statement clause lines 186–194
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, " …
SQL UPDATE syntax reference lines 602–607
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 …
SQL SELECT syntax reference lines 698–702
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

Keyboard shortcuts on this page: j for the next sample, k for the previous one, x to go back to the feed, d to download the original bytes, r to re-queue the sample for analysis.