diff --git a/app/corpora/events.py b/app/corpora/events.py
index 8be48a44..4132bbbf 100644
--- a/app/corpora/events.py
+++ b/app/corpora/events.py
@@ -27,8 +27,8 @@ 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():
+        corpus = Corpus.query.filter_by(id=corpus_id).first()
         cqi_client = CQiClient(host=corpus.analysis_container_ip)
         cqi_client.ctrl_connect('opaque', 'opaque')
         while session_id in connected_sessions: