ifieryarrows's picture
Sync from GitHub (tests passed)
b3b36f7 verified
raw
history blame contribute delete
225 Bytes
"""
Queue adapters for Redis/arq.
"""
from adapters.queue.redis import get_redis_pool, RedisSettings
from adapters.queue.jobs import enqueue_pipeline_job
__all__ = ["get_redis_pool", "RedisSettings", "enqueue_pipeline_job"]