sporada/nopaque
1
0
Fork 0
mirror of https://gitlab.ub.uni-bielefeld.de/sfb1288inf/nopaque.git synced 2025-06-12 09:00:40 +00:00
Code Issues Projects Releases Wiki Activity

small updates

Browse Source
This commit is contained in:
Patrick Jentsch
2020-03-29 20:33:00 +02:00
parent d07b73781f
commit 4ff372de77
2 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
app/corpora/pj_events.py
View File

@ -1,7 +1,8 @@
from flask import current_app, request
from flask_login import current_user
from socket import gaierror
from . import cqi
from .. import db, socketio
from .. import db, logger, socketio
from ..decorators import socketio_login_required
from ..events import connected_sessions
from ..models import Corpus, User
@ -93,7 +94,7 @@ def pj_corpus_analysis_session_handler(app, corpus_id, user_id, session_id):
socketio.sleep(3)
client = cqi.CQiClient('corpus_{}_analysis'.format(corpus_id))
try:
client.connect()
connect_status = client.connect()
except cqi.errors.CQiException as e:
response = {'code': 500, 'desc': None,
'msg': 'Internal Server Error',
@ -101,12 +102,18 @@ def pj_corpus_analysis_session_handler(app, corpus_id, user_id, session_id):
'msg': e.name}}
socketio.emit('pj_corpus_analysis_init', response, room=session_id)
return
except gaierror:
response = {'code': 500, 'desc': None,
'msg': 'Internal Server Error'}
socketio.emit('pj_corpus_analysis_init', response, room=session_id)
return
pj_corpus_analysis_clients[session_id] = client
if corpus_id not in pj_corpus_analysis_sessions:
pj_corpus_analysis_sessions[corpus_id] = [session_id]
else:
pj_corpus_analysis_sessions[corpus_id].append(session_id)
response = {'code': 200, 'desc': None, 'msg': 'OK'}
response = {'code': 200, 'desc': None, 'msg': 'OK',
'payload': {**connect_status}}
socketio.emit('pj_corpus_analysis_init', response, room=session_id)
''' Observe analysis session '''
while session_id in connected_sessions: