diff --git a/swh/storage/archiver/tasks.py b/swh/storage/archiver/tasks.py index 1086f396..78549fc5 100644 --- a/swh/storage/archiver/tasks.py +++ b/swh/storage/archiver/tasks.py @@ -1,26 +1,28 @@ -# Copyright (C) 2015 The Software Heritage developers +# Copyright (C) 2015-2016 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 .worker import ArchiverWithRetentionPolicyWorker from .worker import ArchiverToBackendWorker class SWHArchiverWithRetentionPolicyTask(Task): - """ Main task that archive a batch of content. + """Main task that archive a batch of content. + """ task_queue = 'swh_storage_archive_worker' def run(self, *args, **kwargs): ArchiverWithRetentionPolicyWorker(*args, **kwargs).run() class SWHArchiverToBackendTask(Task): - """ Main task that archive a batch of content in the cloud. + """Main task that archive a batch of content in the cloud. + """ task_queue = 'swh_storage_archive_worker_to_backend' def run(self, *args, **kwargs): ArchiverToBackendWorker(*args, **kwargs).run()