From d90c00501e1dd1ad6f0483195d5911c37f76cd6f Mon Sep 17 00:00:00 2001 From: lowercase00 <21188280+lowercase00@users.noreply.github.com> Date: Fri, 27 Jan 2023 04:22:57 -0300 Subject: [PATCH] Fix Scheduler Docstring (#1768) --- rq/registry.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rq/registry.py b/rq/registry.py index d9889819..d3c141d5 100644 --- a/rq/registry.py +++ b/rq/registry.py @@ -336,7 +336,7 @@ class ScheduledJobRegistry(BaseRegistry): return connection.zremrangebyscore(self.key, 0, score) def get_jobs_to_schedule(self, timestamp: t.Optional[datetime] = None, chunk_size: int = 1000): - """Remove jobs whose timestamp is in the past from registry.""" + """Get's a list of job IDs that should be scheduled.""" score = timestamp if timestamp is not None else current_timestamp() return [as_text(job_id) for job_id in self.connection.zrangebyscore(self.key, 0, score, start=0, num=chunk_size)]