From 816848548f08e1461c3f5a846e21cf4092a62ed5 Mon Sep 17 00:00:00 2001
From: thomaswoehlke <thomas.woehlke@gmail.com>
Date: Sat, 20 Feb 2021 20:22:43 +0100
Subject: [PATCH] working for 0.0.198 Release
---
src/app.py | 13 +++++++++
.../application/application_workers.py | 27 ++++++++++++++++++-
2 files changed, 39 insertions(+), 1 deletion(-)
create mode 100644 src/app.py
diff --git a/src/app.py b/src/app.py
new file mode 100644
index 00000000..e15da707
--- /dev/null
+++ b/src/app.py
@@ -0,0 +1,13 @@
+import sys
+import subprocess
+import covid19
+import covid19_worker
+from covid19 import app
+from covid19.blueprints.application.application_workers import run_app
+
+# ---------------------------------------------------------------------------------
+# MAIN
+# ---------------------------------------------------------------------------------
+
+if __name__ == '__main__':
+ run_app(app)
diff --git a/src/covid19/blueprints/application/application_workers.py b/src/covid19/blueprints/application/application_workers.py
index 0c8964d0..9764eefc 100644
--- a/src/covid19/blueprints/application/application_workers.py
+++ b/src/covid19/blueprints/application/application_workers.py
@@ -1,7 +1,7 @@
import sys
import subprocess
from covid19 import app
-from database import create_celery
+from database import create_celery, run_run_with_debug, port
def run_mq(my_app, my_celery):
@@ -20,4 +20,29 @@ def run_mq(my_app, my_celery):
my_celery.start(args)
+def run_app(my_app):
+ if sys.platform != 'linux':
+ my_app.logger.info("-------------------------------------------------------------")
+ my_app.logger.info("# start REDIS-Server #")
+ my_app.logger.info("-------------------------------------------------------------")
+ redis_cmd = ['redis-server']
+ subprocess.Popen(redis_cmd, shell=True)
+ my_app.logger.info(" ")
+ my_app.logger.info("#############################################################")
+ my_app.logger.info("# Covid19 Data - WORKER #")
+ my_app.logger.info("#############################################################")
+ my_app.logger.info(" ")
+ celery_cmd = ['celery', 'worker', '-l', 'INFO']
+ subprocess.Popen(celery_cmd, shell=True)
+ my_app.logger.info(" ")
+ my_app.logger.info("#############################################################")
+ my_app.logger.info("# Covid19 Data - WEB #")
+ my_app.logger.info("#############################################################")
+ my_app.logger.info(" ")
+ my_app.run(
+ debug=run_run_with_debug,
+ port=port
+ )
+
+
celery = create_celery(app)
--
GitLab