rq_scheduler/scheduler.py
def enqueue_at(self, scheduled_time, func, *args, **kwargs):
        """
        Pushes a job to the scheduler queue. The scheduled queue is a Redis sorted
        set ordered by timestamp - which in this case is job's scheduled execution time.

        All args and kwargs are passed onto the job, except for the following kwarg
        keys (which affect the job creation itself):
        - timeout
        - job_id
        - job_ttl
        - job_result_ttl
        - job_description
        - depends_on
        - meta
        - queue_name

        Usage:

        from datetime import datetime
        from redis import Redis
        from rq.scheduler import Scheduler

        from foo import func

        redis = Redis()
        scheduler = Scheduler(queue_name='default', connection=redis)
        scheduler.enqueue_at(datetime(2020, 1, 1), func, 'argument', keyword='argument')
        """
        timeout = kwargs.pop('timeout', None)
        job_id = kwargs.pop('job_id', None)
        job_ttl = kwargs.pop('job_ttl', None)
        job_result_ttl = kwargs.pop('job_result_ttl', None)
        job_description = kwargs.pop('job_description', None)
        depends_on = kwargs.pop('depends_on', None)
        meta = kwargs.pop('meta', None)
        queue_name = kwargs.pop('queue_name', None)

        job = self._create_job(func, args=args, kwargs=kwargs, timeout=timeout,
                               id=job_id, result_ttl=job_result_ttl, ttl=job_ttl,
                               description=job_description, meta=meta, queue_name=queue_name, depends_on=depends_on)
        self.connection.zadd(self.scheduled_jobs_key,
                              {job.id: to_unix(scheduled_time)})
        return job

        Pushes a job to the scheduler queue. The scheduled queue is a Redis sorted
        set ordered by timestamp - which in this case is job's scheduled execution time.

        All args and kwargs are passed onto the job, except for the following kwarg
        keys (which affect the job creation itself):
        - timeout
        - job_id
        - job_ttl
        - job_result_ttl
        - job_description
        - depends_on
        - meta
        - queue_name

        Usage:

        from datetime import datetime
        from redis import Redis
        from rq.scheduler import Scheduler

        from foo import func

        redis = Redis()
        scheduler = Scheduler(queue_name='default', connection=redis)
        scheduler.enqueue_at(datetime(2020, 1, 1), func, 'argument', keyword='argument')
        
Pushes a job to the scheduler queue. The scheduled queue is a Redis sorted
set ordered by timestamp - which in this case is job's scheduled execution time.

All args and kwargs are passed onto the job, except for the following kwarg
keys (which affect the job creation itself):
timeout
job_id
job_ttl
job_result_ttl
job_description
depends_on
meta
queue_name



from datetime import datetime
from redis import Redis
from rq.scheduler import Scheduler

from foo import func


Pushes a job to the scheduler queue . The scheduled queue is a Redis sorted set ordered by timestamp - which in this case is job ' s scheduled execution time . All args and kwargs are passed onto the job except for the following kwarg keys ( which affect the job creation itself ) : timeout job_id job_ttl job_result_ttl job_description depends_on meta queue_name from datetime import datetime from redis import Redis from rq . scheduler import Scheduler from foo import func
def enqueue_at(self, scheduled_time, func, *args, **kwargs):
        timeout = kwargs.pop('timeout', None)
        job_id = kwargs.pop('job_id', None)
        job_ttl = kwargs.pop('job_ttl', None)
        job_result_ttl = kwargs.pop('job_result_ttl', None)
        job_description = kwargs.pop('job_description', None)
        depends_on = kwargs.pop('depends_on', None)
        meta = kwargs.pop('meta', None)
        queue_name = kwargs.pop('queue_name', None)
        job = self._create_job(func, args=args, kwargs=kwargs, timeout=timeout,
                               id=job_id, result_ttl=job_result_ttl, ttl=job_ttl,
                               description=job_description, meta=meta, queue_name=queue_name, depends_on=depends_on)
        self.connection.zadd(self.scheduled_jobs_key,
                              {job.id: to_unix(scheduled_time)})
        return job
def enqueue_at ( self , scheduled_time , func , * args , ** kwargs ) : timeout = kwargs . pop ( 'timeout' , None ) job_id = kwargs . pop ( 'job_id' , None ) job_ttl = kwargs . pop ( 'job_ttl' , None ) job_result_ttl = kwargs . pop ( 'job_result_ttl' , None ) job_description = kwargs . pop ( 'job_description' , None ) depends_on = kwargs . pop ( 'depends_on' , None ) meta = kwargs . pop ( 'meta' , None ) queue_name = kwargs . pop ( 'queue_name' , None ) job = self . _create_job ( func , args = args , kwargs = kwargs , timeout = timeout , id = job_id , result_ttl = job_result_ttl , ttl = job_ttl , description = job_description , meta = meta , queue_name = queue_name , depends_on = depends_on ) self . connection . zadd ( self . scheduled_jobs_key , { job . id : to_unix ( scheduled_time ) } ) return job
Pushes a job to the scheduler queue.
Pushes a job to the scheduler queue .
"""
        Pushes a job to the scheduler queue. The scheduled queue is a Redis sorted
        set ordered by timestamp - which in this case is job's scheduled execution time.

        All args and kwargs are passed onto the job, except for the following kwarg
        keys (which affect the job creation itself):
        - timeout
        - job_id
        - job_ttl
        - job_result_ttl
        - job_description
        - depends_on
        - meta
        - queue_name

        Usage:

        from datetime import datetime
        from redis import Redis
        from rq.scheduler import Scheduler

        from foo import func

        redis = Redis()
        scheduler = Scheduler(queue_name='default', connection=redis)
        scheduler.enqueue_at(datetime(2020, 1, 1), func, 'argument', keyword='argument')
        """
self
scheduled_time
func