rq_scheduler/scheduler.py
def enqueue_in(self, time_delta, func, *args, **kwargs):
        """
        Similar to ``enqueue_at``, but accepts a timedelta instead of datetime object.
        The job's scheduled execution time will be calculated by adding the timedelta
        to datetime.utcnow().
        """
        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(datetime.utcnow() + time_delta)})
        return job

        Similar to ``enqueue_at``, but accepts a timedelta instead of datetime object.
        The job's scheduled execution time will be calculated by adding the timedelta
        to datetime.utcnow().
        
Similar to ``enqueue_at``, but accepts a timedelta instead of datetime object.
The job's scheduled execution time will be calculated by adding the timedelta
to datetime.utcnow().
Similar to ` ` enqueue_at ` ` but accepts a timedelta instead of datetime object . The job ' s scheduled execution time will be calculated by adding the timedelta to datetime . utcnow () .
def enqueue_in(self, time_delta, 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(datetime.utcnow() + time_delta)})
        return job
def enqueue_in ( self , time_delta , 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 ( datetime . utcnow ( ) + time_delta ) } ) return job
Similar to ``enqueue_at``, but accepts a timedelta instead of datetime object.
Similar to ` ` enqueue_at ` ` but accepts a timedelta instead of datetime object .
"""
        Similar to ``enqueue_at``, but accepts a timedelta instead of datetime object.
        The job's scheduled execution time will be calculated by adding the timedelta
        to datetime.utcnow().
        """
self
time_delta
func