mirror of
https://github.com/hatchet-dev/hatchet.git
synced 2026-01-06 00:40:10 -06:00
[Python]: Fix: Adding Observability + Failure Handling (#1701)
* feat: simple thread pool monitoring job * feat: sdk-side workflow pause * Revert "feat: sdk-side workflow pause" This reverts commit83b4a63c20. * feat: set stop signal to stop accepting new work * proposal: no-op healthcheck workflow * Revert "proposal: no-op healthcheck workflow" This reverts commitf651a52137. * fix: rm removed concurrency strats * chore: ver * fix: rm heartbeat wf * fix: rm zombie keys * fix: hint on invalid token * fix: flaky test * fix: rm buggy / dead code
This commit is contained in:
@@ -278,7 +278,7 @@ async def crons(
|
||||
|
||||
def time_until_next_minute() -> float:
|
||||
now = datetime.now()
|
||||
next_minute = now.replace(second=0, microsecond=0, minute=now.minute + 1)
|
||||
next_minute = (now + timedelta(minutes=1)).replace(second=0, microsecond=0)
|
||||
|
||||
return (next_minute - now).total_seconds()
|
||||
|
||||
|
||||
Reference in New Issue
Block a user