Changeset View
Changeset View
Standalone View
Standalone View
swh/storage/archiver/tasks.py
| # Copyright (C) 2015 The Software Heritage developers | # Copyright (C) 2015 The Software Heritage developers | ||||
| # See the AUTHORS file at the top-level directory of this distribution | # See the AUTHORS file at the top-level directory of this distribution | ||||
| # License: GNU General Public License version 3, or any later version | # License: GNU General Public License version 3, or any later version | ||||
| # See top-level LICENSE file for more information | # See top-level LICENSE file for more information | ||||
| from swh.scheduler.task import Task | from swh.scheduler.task import Task | ||||
| from .worker import ArchiverWorker | from .worker import ArchiverWorker | ||||
| class SWHArchiverTask(Task): | class SWHArchiverTask(Task): | ||||
| """ Main task that archive a batch of content. | """ Main task that archive a batch of content. | ||||
| """ | """ | ||||
| task_queue = 'swh_storage_archive_worker' | task_queue = 'swh_storage_archive_worker' | ||||
| def run(self, batch, master_storage_args, | def run(self, batch, master_storage_args, | ||||
| slave_storages, retention_policy): | slave_storages, config): | ||||
| aw = ArchiverWorker(batch, master_storage_args, | aw = ArchiverWorker(batch, master_storage_args, | ||||
| slave_storages, retention_policy) | slave_storages, config) | ||||
| if aw.run(): | if aw.run(): | ||||
| self.log("Successful backup for a batch of size %s" % len(batch)) | self.log("Successful backup for a batch of size %s" % len(batch)) | ||||