ec818a5523
* refactor: move all background task from rqworker to celery * dev: update background job to take input in parameters rather than a single dict * dev: update procfile for new worker * dev: docker updates for new celery worker
23 lines
558 B
Python
23 lines
558 B
Python
import os
|
|
import redis
|
|
from django.conf import settings
|
|
from urllib.parse import urlparse
|
|
|
|
|
|
def redis_instance():
|
|
# connect to redis
|
|
if settings.DOCKERIZED or os.environ.get(
|
|
"DJANGO_SETTINGS_MODULE", "plane.settings.local"
|
|
):
|
|
ri = redis.Redis.from_url(settings.REDIS_URL, db=0)
|
|
else:
|
|
url = urlparse(settings.REDIS_URL)
|
|
ri = redis.Redis(
|
|
host=url.hostname,
|
|
port=url.port,
|
|
password=url.password,
|
|
ssl=True,
|
|
ssl_cert_reqs=None,
|
|
)
|
|
|
|
return ri
|