Function task_id_in_map

celery/contrib/migrate.py:384–385

(body, message)

        ...   queues=['hipri'])
    """
    def task_id_in_map(body, message):
        return map.get(message.properties['correlation_id'])

    # adding the limit means that we don't have to consume any more
    # when we've found everything.