Fix task args order when harvesting by source ID.
@@ -79,5 +79,5 @@ class Command(BaseCommand):
harvester = config.harvester(config)
for id in options['ids']:
raw = harvester.harvest_by_id(id)
- task = NormalizerTask().apply_async((config.label, user.id, raw.id,))
+ task = NormalizerTask().apply_async((user.id, config.label, raw.id,))
self.stdout.write('Raw data {} harvested from {}, saved as {}. Started normalizer task {}.'.format(id, app_name, raw.id, task))
