Loading docker-compose.yml +2 −1 Original line number Diff line number Diff line Loading @@ -21,7 +21,8 @@ services: depends_on: - rabbitmq environment: BROKER_URL: &broker_url amqp://waldorf:pass@rabbitmq/waldorf # yamllint disable-line rule:line-length BROKER_URL: &broker_url amqp://waldorf:pass@rabbitmq/waldorf # pragma: allowlist secret FLASK_APP: server FLASK_ENV: development healthcheck: Loading server.py +1 −1 Original line number Diff line number Diff line """Dummy web server using Flask.""" from flask import Flask, request, jsonify from flask import Flask, request, jsonify # pylint: disable=import-error import tasks app = Flask(__name__) # pylint: disable=invalid-name Loading tasks.py +2 −2 Original line number Diff line number Diff line """Celery worker.""" import logging import os from celery import Celery from celery import Celery # pylint: disable=import-error BROKER_URL = os.getenv("BROKER_URL") Loading @@ -11,4 +11,4 @@ app = Celery("tasks", broker=BROKER_URL) # pylint: disable=invalid-name @app.task def log(message): """Log message.""" logging.info(f"Message: %s", message) logging.info("Message: %s", message) Loading
docker-compose.yml +2 −1 Original line number Diff line number Diff line Loading @@ -21,7 +21,8 @@ services: depends_on: - rabbitmq environment: BROKER_URL: &broker_url amqp://waldorf:pass@rabbitmq/waldorf # yamllint disable-line rule:line-length BROKER_URL: &broker_url amqp://waldorf:pass@rabbitmq/waldorf # pragma: allowlist secret FLASK_APP: server FLASK_ENV: development healthcheck: Loading
server.py +1 −1 Original line number Diff line number Diff line """Dummy web server using Flask.""" from flask import Flask, request, jsonify from flask import Flask, request, jsonify # pylint: disable=import-error import tasks app = Flask(__name__) # pylint: disable=invalid-name Loading
tasks.py +2 −2 Original line number Diff line number Diff line """Celery worker.""" import logging import os from celery import Celery from celery import Celery # pylint: disable=import-error BROKER_URL = os.getenv("BROKER_URL") Loading @@ -11,4 +11,4 @@ app = Celery("tasks", broker=BROKER_URL) # pylint: disable=invalid-name @app.task def log(message): """Log message.""" logging.info(f"Message: %s", message) logging.info("Message: %s", message)