def apply(self, job_name, args=(), kwargs={}, **opts):
        queue = QueueType(self.get_queue_name(job_name), connection=self.connection, async=False)
        return queue.enqueue_call(
            job_name, args=args, kwargs=kwargs,
            result_ttl=0, timeout=DEFAULT_JOB_TIMEOUT, **opts
        )
Run a job in-process.
dataset/ETHPy150Open getsentry/freight/freight/queue.py/Queue.apply