mirror of
https://gitlab.ub.uni-bielefeld.de/sfb1288inf/nopaque.git
synced 2024-11-15 09:15:41 +00:00
32 lines
965 B
Python
32 lines
965 B
Python
from config import config
|
|
from sqlalchemy import create_engine
|
|
from sqlalchemy.orm import scoped_session, sessionmaker
|
|
from time import sleep
|
|
import docker
|
|
import os
|
|
|
|
|
|
configuration = config[os.environ.get('NOPAQUE_CONFIG', 'development')]
|
|
configuration.init()
|
|
docker_client = docker.from_env()
|
|
engine = create_engine(configuration.SQLALCHEMY_DATABASE_URI)
|
|
Session = scoped_session(sessionmaker(bind=engine))
|
|
|
|
|
|
def run():
|
|
from .tasks.check_corpora import check_corpora
|
|
check_corpora_thread = check_corpora()
|
|
from .tasks.check_jobs import check_jobs
|
|
check_jobs_thread = check_jobs()
|
|
from .tasks.notify import notify
|
|
notify_thread = notify()
|
|
|
|
while True:
|
|
if not check_corpora_thread.is_alive():
|
|
check_corpora_thread = check_corpora()
|
|
if not check_jobs_thread.is_alive():
|
|
check_jobs_thread = check_jobs()
|
|
if not notify_thread.is_alive():
|
|
notify_thread = notify()
|
|
sleep(3)
|