Source code for materializationengine.task_router

class TaskRouter(object):
    def route_for_task(self, task, *args, **kwargs):
        if ":" not in task:
            return {"queue": "celery"}
        namespace, _ = task.split(":")
        return {"queue": namespace}