'For EC we can potentially revert only some of a partition
so we\'ll delete reverted objects here. Note that we delete
the fragment index of the file we sent to the remote node.
:param job: the job being processed
:param objects: a dict of objects to be deleted, each entry maps
hash=>timestamp
:param frag_index: (int) the fragment index of data files to be deleted'

def delete_reverted_objs(self, job, objects, frag_index):

    df_mgr = self._df_router[job['policy']]
    for (object_hash, timestamps) in objects.items():
        try:
            df = df_mgr.get_diskfile_from_hash(job['local_dev']['device'], job['partition'], object_hash, job['policy'], frag_index=frag_index)
            df.purge(timestamps['ts_data'], frag_index)
        except DiskFileError:
            self.logger.exception('Unable    to    purge    DiskFile    (%r    %r    %r)', object_hash, timestamps['ts_data'], frag_index)
