diff options
Diffstat (limited to 'web/app/job_manager.py')
-rw-r--r-- | web/app/job_manager.py | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/web/app/job_manager.py b/web/app/job_manager.py new file mode 100644 index 0000000..60c4635 --- /dev/null +++ b/web/app/job_manager.py @@ -0,0 +1,16 @@ +from rq import Queue +from redis import Redis +from jobs.scrape_cases import scrape_cases + +class JobManager: + def __init__(self): + redis = Redis() + self.q = Queue(connection=redis) + + def enqueue_scrape(self, act, section, state_code): + return self.q.enqueue( + scrape_cases, + act, + section, + state_code + ) |