Set up all things for first query

This commit is contained in:
Stephan Porada
2019-11-07 10:45:12 +01:00
parent 414ebc73ff
commit 47440880d5
4 changed files with 42 additions and 6 deletions

View File

@ -27,13 +27,13 @@ def recv_query(message):
def observe_corpus_analysis_connection(app, corpus_id, session_id):
logger = logging.getLogger(__name__)
corpus = Corpus.query.filter_by(id=corpus_id).first()
with app.app_context():
cqi_client = CQiClient(host='172.25.0.2')
cqi_client = CQiClient(host=corpus.analysis_container_ip)
while session_id in connected_sessions:
logger.warning(cqi_client.ctrl_ping())
logger.warning('Run container, run!')
socketio.sleep(3)
corpus = Corpus.query.filter_by(id=corpus_id).first()
corpus.status = 'stop analysis'
db.session.commit()
logger.warning('Stop container, stop!')