diff --git a/docs/dev-info.rst b/docs/dev-info.rst --- a/docs/dev-info.rst +++ b/docs/dev-info.rst @@ -72,7 +72,7 @@ slicing: 0:1/1:5 root: /home/storage/swh-storage/ - destination_queue: swh.indexer.tasks.SWHOrchestratorTextContentsTask + destination_task: swh.indexer.tasks.SWHOrchestratorTextContentsTask rescheduling_task: swh.indexer.tasks.SWHContentMimetypeTask diff --git a/swh/indexer/mimetype.py b/swh/indexer/mimetype.py --- a/swh/indexer/mimetype.py +++ b/swh/indexer/mimetype.py @@ -40,7 +40,7 @@ """ ADDITIONAL_CONFIG = { - 'destination_queue': ('str', None), + 'destination_task': ('str', None), 'tools': ('dict', { 'name': 'file', 'version': '1:5.30-1+deb9u1', @@ -55,9 +55,9 @@ def prepare(self): super().prepare() - destination_queue = self.config.get('destination_queue') - if destination_queue: - self.task_destination = utils.get_task(destination_queue) + destination_task = self.config.get('destination_task') + if destination_task: + self.task_destination = utils.get_task(destination_task) else: self.task_destination = None self.tool = self.tools[0] diff --git a/swh/indexer/tests/test_language.py b/swh/indexer/tests/test_language.py --- a/swh/indexer/tests/test_language.py +++ b/swh/indexer/tests/test_language.py @@ -30,7 +30,7 @@ """ def prepare(self): self.config = { - 'destination_queue': None, + 'destination_task': None, 'rescheduling_task': None, 'tools': { 'name': 'pygments', diff --git a/swh/indexer/tests/test_mimetype.py b/swh/indexer/tests/test_mimetype.py --- a/swh/indexer/tests/test_mimetype.py +++ b/swh/indexer/tests/test_mimetype.py @@ -33,7 +33,7 @@ """ def prepare(self): self.config = { - 'destination_queue': None, + 'destination_task': None, 'rescheduling_task': None, 'tools': { 'name': 'file', @@ -49,7 +49,7 @@ self.objstorage = MockObjStorage() self.task_destination = None self.rescheduling_task = self.config['rescheduling_task'] - self.destination_queue = self.config['destination_queue'] + self.destination_task = self.config['destination_task'] self.tools = self.register_tools(self.config['tools']) self.tool = self.tools[0]