blob: 60c46353f41bbe2f28e6c6a38ee174048890c863 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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
)
|
