modify

c39da376 · 段英荣 · 9269f237 · c39da376
Commit c39da376 authored Dec 10, 2018 by 段英荣
Hide whitespace changes
Inline Side-by-side

Showing with 2 additions and 2 deletions

celery_task_router.py physical/celery_task_router.py +2 -2

No files found.
--- a/physical/celery_task_router.py
+++ b/physical/celery_task_router.py
@@ -8,9 +8,9 @@ import logging

 class CeleryTaskRouter(object):
    queue_task_map = {
-        "tapir-alpha":{
+        "tapir-alpha":[
            'injection.data_sync.tasks.write_to_es',
-        }
+        ]
    }

    # Map[TaskName, QueueName]