self.add_processor(Resizer)
self.add_processor(MetadataProcessing)
- def workflow(self, entry, feed_url, reprocess_action, reprocess_info=None):
+ def workflow(self, entry, manager, feed_url, reprocess_action,
+ reprocess_info=None):
ProcessMedia().apply_async(
[entry.id, feed_url, reprocess_action, reprocess_info], {},
task_id=entry.queued_task_id)