|
@@ -476,7 +476,7 @@ All you need to define a new router is to create a class with a
|
|
|
|
|
|
class MyRouter(object):
|
|
|
|
|
|
- def route_for_task(task, args=None, kwargs=None):
|
|
|
+ def route_for_task(self, task, args=None, kwargs=None):
|
|
|
if task == "myapp.tasks.compress_video":
|
|
|
return {"exchange": "video",
|
|
|
"exchange_type": "topic",
|