return self.RevisionMetadataTask().apply_async(            
                kwargs={                                           
                    'ids': [res['revision_id'] for res in results],
                    'policy_update': 'update-dups',                
                    },                                             
                link=self.OriginMetadataTask().s(                  
                    map_=origin_to_revision,                       
                    policy_update='update-dups'),                  
                )