misc: change start time for cron datetime retriever

Author: d3nbr0

aiocarrot/scheduler/types.py

@@ -22,8 +22,11 @@ class Task:
     def __init__(self, carrot: 'Carrot', message: 'Message') -> None:
         self._carrot = carrot
         self._message = message
-        self._cron = croniter(message.schedule, datetime.now(timezone.utc))
-        self._sync()
+
+        now = datetime.now(timezone.utc)
+
+        self._cron = croniter(message.schedule, now)
+        self._sync(now)
 
     async def run(self):
         logger.info(f'Scheduled task <{self._message.name}> has been queued')
@@ -32,16 +35,16 @@ async def run(self):
 
     def is_due(self, now: datetime) -> bool:
         if self._resync_at_next_tick:
-            self._sync()
+            self._sync(now)
 
         return now >= self._next_run
 
     @property
     def next_run(self) -> datetime:
         return self._next_run
 
-    def _sync(self) -> None:
-        self._next_run = self._cron.get_next(datetime)
+    def _sync(self, start_datetime: datetime) -> None:
+        self._next_run = self._cron.get_next(datetime, start_time=start_datetime)
         self._resync_at_next_tick = False