# Schedule a job to run 10 minutes, 1 hour and 1 day later We could do something like from datetime import timedelta Monitor how popular a tweet is a few times during the course of the day, Object, this method expects a timedelta and schedules the job to runĪt X seconds/minutes/hours/days/weeks later. Scheduler.enqueue_at(datetime( 2020, 1, 1), func) # The job will be enqueued at the queue named "foo" using the queue type "rq.Queue"
Scheduler = Scheduler( 'foo', queue_class= "rq.Queue") # You can choose the queue type where jobs will be enqueued by passing the name of the type to the scheduler # used to enqueue Scheduler.enqueue_at(datetime( 2020, 1, 1), func) # Date time should be in UTC # Here's another example scheduling a job to run at a specific date and time (in UTC), # complete with args and kwargs. So for example to schedule a # job to run on Jan 1st 2020 we do: The API is similar to RQ except that it # takes a datetime object as first argument. Scheduler = Scheduler(queue=queue, connection=nnection) Queue = Queue( 'bar', connection=Redis()) Scheduler = Scheduler( 'foo', connection=Redis()) # Get a scheduler for the "foo" queue # You can also instantiate a Scheduler using an RQ Queue Scheduler = Scheduler(connection=Redis()) # Get a scheduler for the "default" queue Scheduler's enqueue_at from redis import Redis There are two ways you can schedule a job.
Running a scheduler that will move scheduled jobs into queues when.Schedule a job involves doing two different things: Or you can download the latest stable package from
#Rqscheduler install#
You can install RQ Scheduler via pip: pip install rq-scheduler If you find rq-scheduler useful, please consider supporting its
0 kommentar(er)
