diff --git a/swh/vault/cooking_tasks.py b/swh/vault/cooking_tasks.py index 1e1e682..64e49de 100644 --- a/swh/vault/cooking_tasks.py +++ b/swh/vault/cooking_tasks.py @@ -1,18 +1,18 @@ # Copyright (C) 2016-2017 The Software Heritage developers # See the AUTHORS file at the top-level directory of this distribution # License: GNU General Public License version 3, or any later version # See top-level LICENSE file for more information from swh.scheduler.task import Task from swh.vault.cookers import COOKER_TYPES class SWHCookingTask(Task): """Main task which archives a contents batch. """ - task_queue = 'swh_storage_vault_cooking' + task_queue = 'swh_vault_cooking' def run(self, config, obj_type, obj_id): cooker = COOKER_TYPES[obj_type](config, obj_type, obj_id) cooker.cook()