prepare for multi-node deployment

This commit is contained in:
Marvin Zhang
2019-02-26 13:00:06 +08:00
parent 8b8db8e94e
commit be887cef22
4 changed files with 28 additions and 2 deletions

View File

@@ -1,6 +1,14 @@
from config.celery import BROKER_URL
import os
import sys
import subprocess
# make sure the working directory is in system path
file_dir = os.path.dirname(os.path.realpath(__file__))
root_path = os.path.abspath(os.path.join(file_dir, '..'))
sys.path.append(root_path)
from config.celery import BROKER_URL
if __name__ == '__main__':
p = subprocess.Popen(['celery', 'flower', '-b', BROKER_URL], stdout=subprocess.PIPE, stderr=subprocess.STDOUT)
for line in iter(p.stdout.readline, 'b'):