opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-10-25 00:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

Allow specifying connection at launch of GalaxyQueueWorker.

Browse Source
This commit is contained in:
Dannon Baker
2015-02-08 18:02:26 -05:00
parent 8b03d0f9d9
commit c74448cd57
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/queue_worker.py
+5 -2
View File
@@ -30,10 +30,13 @@ class GalaxyQueueWorker(ConsumerMixin, threading.Thread):
handler, will have one of these used for dispatching so called 'control'
tasks.
"""
def __init__(self, app, queue, task_mapping):
def __init__(self, app, queue, task_mapping, connection=None):
super(GalaxyQueueWorker, self).__init__()
log.info("Initalizing Galaxy Queue Worker on %s" % app.config.amqp_internal_connection)
self.connection = Connection(app.config.amqp_internal_connection)
if connection:
self.connection = connection
else:
self.connection = Connection(app.config.amqp_internal_connection)
self.app = app
# Eventually we may want different workers w/ their own queues and task
# mappings. Right now, there's only the one.