opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-09-24 16:30:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

No mutable default args

Browse Source
This commit is contained in:
mvdbeek
2019-08-18 16:01:32 +02:00
parent b99fa24e36
commit 5791ea17af
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/queue_worker.py
+6 -2
View File
@@ -29,11 +29,13 @@ logging.getLogger('kombu').setLevel(logging.WARNING)
log = logging.getLogger(__name__)
def send_local_control_task(app, task, kwargs={}):
def send_local_control_task(app, task, kwargs=None):
"""
This sends a message to the process-local control worker, which is useful
for one-time asynchronous tasks like recalculating user disk usage.
"""
if kwargs is None:
kwargs = {}
log.info("Queuing async task %s for %s." % (task, app.config.server_name))
payload = {'task': task,
'kwargs': kwargs}
@@ -42,7 +44,7 @@ def send_local_control_task(app, task, kwargs={}):
control_task.send_task(payload, routing_key, local=True, get_response=False)
def send_control_task(app, task, noop_self=False, get_response=False, routing_key='control.*', kwargs={}):
def send_control_task(app, task, noop_self=False, get_response=False, routing_key='control.*', kwargs=None):
"""
This sends a control task out to all processes, useful for things like
reloading a data table, which needs to happen individually in all
@@ -51,6 +53,8 @@ def send_control_task(app, task, noop_self=False, get_response=False, routing_ke
Set get_response to True to wait for and return the task results
as a list.
"""
if kwargs is None:
kwargs = {}
log.info("Sending %s control task." % task)
payload = {'task': task,
'kwargs': kwargs}