diff --git a/app/corpora/events.py b/app/corpora/events.py
index 1fc3fb5d..d3902f8a 100644
--- a/app/corpora/events.py
+++ b/app/corpora/events.py
@@ -125,7 +125,7 @@ def corpus_analysis_session_handler(app, corpus_id, user_id, session_id):
         while corpus.status != 'analysing':
             db.session.refresh(corpus)
             socketio.sleep(3)
-        client = cqi.CQiClient('corpus_{}_analysis'.format(corpus_id))
+        client = cqi.CQiClient('cqpserver_{}'.format(corpus_id))
         try:
             payload = client.connect()
         except cqi.errors.CQiException as e: