rq_scheduler/scheduler.py
def _create_job(self, func, args=None, kwargs=None, commit=True,
                    result_ttl=None, ttl=None, id=None, description=None,
                    queue_name=None, timeout=None, meta=None, depends_on=None):
        """
        Creates an RQ job and saves it to Redis. The job is assigned to the
        given queue name if not None else it is assigned to scheduler queue by
        default.
        """
        if args is None:
            args = ()
        if kwargs is None:
            kwargs = {}
        job = self.job_class.create(
                func, args=args, connection=self.connection,
                kwargs=kwargs, result_ttl=result_ttl, ttl=ttl, id=id,
                description=description, timeout=timeout, meta=meta, depends_on=depends_on)
        if queue_name:
            job.origin = queue_name
        else:
            job.origin = self.queue_name

        if self.queue_class_name:
            job.meta["queue_class_name"] = self.queue_class_name

        if commit:
            job.save()
        return job

        Creates an RQ job and saves it to Redis. The job is assigned to the
        given queue name if not None else it is assigned to scheduler queue by
        default.
        
Creates an RQ job and saves it to Redis. The job is assigned to the
given queue name if not None else it is assigned to scheduler queue by
default.
Creates an RQ job and saves it to Redis . The job is assigned to the given queue name if not None else it is assigned to scheduler queue by default .
def _create_job(self, func, args=None, kwargs=None, commit=True,
                    result_ttl=None, ttl=None, id=None, description=None,
                    queue_name=None, timeout=None, meta=None, depends_on=None):
        if args is None:
            args = ()
        if kwargs is None:
            kwargs = {}
        job = self.job_class.create(
                func, args=args, connection=self.connection,
                kwargs=kwargs, result_ttl=result_ttl, ttl=ttl, id=id,
                description=description, timeout=timeout, meta=meta, depends_on=depends_on)
        if queue_name:
            job.origin = queue_name
        else:
            job.origin = self.queue_name
        if self.queue_class_name:
            job.meta["queue_class_name"] = self.queue_class_name
        if commit:
            job.save()
        return job
def _create_job ( self , func , args = None , kwargs = None , commit = True , result_ttl = None , ttl = None , id = None , description = None , queue_name = None , timeout = None , meta = None , depends_on = None ) : if args is None : args = ( ) if kwargs is None : kwargs = { } job = self . job_class . create ( func , args = args , connection = self . connection , kwargs = kwargs , result_ttl = result_ttl , ttl = ttl , id = id , description = description , timeout = timeout , meta = meta , depends_on = depends_on ) if queue_name : job . origin = queue_name else : job . origin = self . queue_name if self . queue_class_name : job . meta [ "queue_class_name" ] = self . queue_class_name if commit : job . save ( ) return job
Creates an RQ job and saves it to Redis.
Creates an RQ job and saves it to Redis .
"""
        Creates an RQ job and saves it to Redis. The job is assigned to the
        given queue name if not None else it is assigned to scheduler queue by
        default.
        """
self
func
args
kwargs
commit
result_ttl
ttl
id
description
queue_name
timeout
meta
depends_on