def route_for_task(name, args, kwargs, options, task=None, **kw):
    """
    Custom task router for queues
    """
    if ':' in name:
        queue, _ = name.split(':')
        return {'queue': queue}
