diff --git a/dds_web/__init__.py b/dds_web/__init__.py index 4334cec18..ac1ba2d79 100644 --- a/dds_web/__init__.py +++ b/dds_web/__init__.py @@ -29,7 +29,6 @@ import sqlalchemy import structlog import werkzeug -from celery import Celery #################################################################################################### # GLOBAL VARIABLES ############################################################## GLOBAL VARIABLES # @@ -63,9 +62,6 @@ # Migration migrate = flask_migrate.Migrate() -# Celery -celery = Celery() - #################################################################################################### # FUNCTIONS ############################################################################ FUNCTIONS # #################################################################################################### @@ -283,10 +279,6 @@ def load_user(user_id): # Initialize migrations migrate.init_app(app, db) - # Celery - celery = Celery(app.name, broker=app.config["CELERY_BROKER_URL"]) - celery.conf.update(app.config) - # initialize OIDC oauth.init_app(app) oauth.register( diff --git a/dds_web/config.py b/dds_web/config.py index 2636b1542..9f26fcb8d 100644 --- a/dds_web/config.py +++ b/dds_web/config.py @@ -91,6 +91,4 @@ class Config(object): # Logging setup; 0 means no log rotation LOG_MAX_SIZE = os.environ.get("LOG_MAX_SIZE", 0x100000) LOG_BACKUP_COUNT = os.environ.get("LOG_BACKUP_COUNT", 15) - - CELERY_BROKER_URL = 'redis://localhost:6379/0' - CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' \ No newline at end of file + \ No newline at end of file diff --git a/docker-compose.yml b/docker-compose.yml index e3196a9b2..1efcbf889 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -175,10 +175,13 @@ services: source: ../dds_cli target: /code - worker: + celery: build: - context: . - dockerfile: Dockerfiles/backend.Dockerfile + context: . + environment: + FLASK_APP: run + volumes: + - .:/app command: celery -A run.celery worker --loglevel=info - links: + depends_on: - redis \ No newline at end of file