diff --git a/pw_poller.py b/pw_poller.py index 26483e0..78159be 100755 --- a/pw_poller.py +++ b/pw_poller.py @@ -193,9 +193,15 @@ def run(self, life) -> None: secs = 0 while life.next_poll(secs): req_time = datetime.datetime.now() + log_open_sec(f"Querying patchwork at {req_time} since {since}") json_resp, since = self._pw.get_new_series(since=since) log(f"Loaded {len(json_resp)} series", "") + # Advance the time by 1 usec, pw does >= for time comparison + since = datetime.datetime.fromisoformat(since) + since += datetime.timedelta(microseconds=1) + since = since.isoformat() + for pw_series in json_resp: try: self.process_series(pw_series)