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

Delete remaining messages on startup

Browse Source 
So far I don't think we have any messages that should survive
restarts. If we do at some point we should route them differently
(or change the existing worker to use ephemeral messages).
This commit is contained in:
mvdbeek
2019-03-29 21:46:18 +01:00
parent 038db80258
commit 006f42ddd6
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
test/unit/queue_worker/test_queue_worker.py
+2
View File
@@ -77,6 +77,7 @@ def test_send_control_task_get_result(queue_worker_factory):
def test_send_local_control_task_with_non_target_listeners(queue_worker_factory):
app1 = queue_worker_factory('test_server1')
app2 = queue_worker_factory('test_server2')
assert app2.some_var == 'foo'
send_local_control_task(app=app1, task='echo')
wait_for_var(app1, 'some_var', 'bar')
assert app2.some_var == 'foo'
@@ -84,6 +85,7 @@ def test_send_local_control_task_with_non_target_listeners(queue_worker_factory)
def test_send_control_task_noop_self(queue_worker_factory):
app = queue_worker_factory('test_server')
assert app.some_var == 'foo'
response = send_control_task(app=app, task='echo', noop_self=True, get_response=True)
assert response == 'NO_OP'
assert app.some_var == 'foo'