17 lines
384 B
Python
17 lines
384 B
Python
from storage_service.config.config_redis import get_config_redis
|
|
|
|
from redis import Redis
|
|
from rq import Queue, Worker
|
|
|
|
from functools import cache
|
|
|
|
|
|
@cache
|
|
def dependency_queue() -> Queue:
|
|
return Queue(name="default", connection=Redis(**get_config_redis()))
|
|
|
|
|
|
@cache
|
|
def dependency_queue_worker() -> Worker:
|
|
return Worker(["default"], connection=Redis(**get_config_redis()))
|