aboutsummaryrefslogtreecommitdiff
path: root/web/app/job_manager.py
diff options
context:
space:
mode:
Diffstat (limited to 'web/app/job_manager.py')
-rw-r--r--web/app/job_manager.py16
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
+ )