diff --git a/Dockerfile b/Dockerfile index 9c0a7adb6..8f9ea2ae9 100644 --- a/Dockerfile +++ b/Dockerfile @@ -31,6 +31,8 @@ ENV DEFAULT_URL=/uber ENV DEBUG=false ENV SESSION_HOST=redis ENV SESSION_PORT=6379 +ENV SESSION_PREFIX=uber +ENV BROKER_PROTOCOL=amqp ENV BROKER_HOST=rabbitmq ENV BROKER_PORT=5672 ENV BROKER_USER=celery diff --git a/requirements.txt b/requirements.txt index 49401ba1d..55290bc60 100644 --- a/requirements.txt +++ b/requirements.txt @@ -23,4 +23,8 @@ fpdf==1.7.2 boto3==1.14.45 SQLAlchemy==1.3.0 Jinja2==2.11.3 -pyyaml==6.0 \ No newline at end of file +requests==2.27.1 +signnow_python_sdk==2.0.1 +Authlib==1.0.1 +pyyaml==6.0 +librabbitmq==2.0.0 \ No newline at end of file diff --git a/sideboard-development.ini.template b/sideboard-development.ini.template index 2ef3d9be8..ee68a25d4 100644 --- a/sideboard-development.ini.template +++ b/sideboard-development.ini.template @@ -11,6 +11,7 @@ server.socket_timeout = 1 server.thread_pool = 100 tools.sessions.host = "${SESSION_HOST}" tools.sessions.port = ${SESSION_PORT} +tools.sessions.prefix = "${SESSION_PREFIX}" tools.sessions.storage_type = "redis" tools.sessions.timeout = 60 diff --git a/uber-development.ini.template b/uber-development.ini.template index 7f7ef9a4c..56006897b 100644 --- a/uber-development.ini.template +++ b/uber-development.ini.template @@ -3,4 +3,4 @@ hostname = "${HOSTNAME}" url_root = "http://${HOSTNAME}:${PORT}" [secret] -broker_url = "amqp://${BROKER_USER}:${BROKER_PASS}@${BROKER_HOST}:${BROKER_PORT}/${BROKER_VHOST}" +broker_url = "${BROKER_PROTOCOL}://${BROKER_USER}:${BROKER_PASS}@${BROKER_HOST}:${BROKER_PORT}/${BROKER_VHOST}" diff --git a/uber/tasks/__init__.py b/uber/tasks/__init__.py index 97e54bd5e..fb8d990a3 100644 --- a/uber/tasks/__init__.py +++ b/uber/tasks/__init__.py @@ -12,8 +12,12 @@ celery.conf.beat_schedule = {} celery.conf.beat_startup_tasks = [] celery.conf.update(config_dict['celery']) -celery.conf.update(broker_url=config_dict['secret']['broker_url']) +broker_url = config_dict['secret']['broker_url'] + +celery.conf.update(broker_url=broker_url) +celery.conf.update(result_backend=broker_url.replace("amqps://", "rpc://")) +celery.conf.update(task_ignore_result=True) def celery_on_startup(fn, *args, **kwargs): celery.conf.beat_startup_tasks.append((celery.task(fn), args, kwargs))