Update scripts.py with rq_queue_name

This commit is contained in:
jchambers2012 2024-06-11 15:37:36 -04:00 committed by GitHub
parent d85cf9ee0d
commit 2455660865
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -373,6 +373,10 @@ class BaseScript:
def scheduling_enabled(self):
return getattr(self.Meta, 'scheduling_enabled', True)
@classproperty
def rq_queue_name(self):
return getattr(self.Meta, 'rq_queue_name', None)
@property
def filename(self):
return inspect.getfile(self.__class__)
@ -713,6 +717,7 @@ def run_script(data, job, request=None, commit=True, **kwargs):
schedule_at=new_scheduled_time,
interval=job.interval,
job_timeout=script.job_timeout,
rq_queue_name=script.rq_queue_name,
data=data,
request=request,
commit=commit