GitLab

Sur FranceArchives nous avons besoin de surcharger les DeleteFileOp.postcommit_event et AddFileOp.postcommit_event pour chaque fichier traité. Serait-il possible d'avoir la possibilité d'appeler du code sur chaque donnée :

class S3DeleteFileOp(DataOperationMixIn, LateOperation):
    containercls = list

    def new_func_process_data(self, storage, key, eid, attr):
        pass

    def postcommit_event(self):
        for storage, key, eid, attr in self.get_data():
            self.info('Deleting object %s.%s (%s/%s) from S3',
                      eid, attr, storage.bucket, key)
            resp = storage.s3cnx.delete_object(Bucket=storage.bucket, Key=key)
            if resp.get('ResponseMetadata', {}).get('HTTPStatusCode') >= 300:
                self.error('S3 object deletion FAILED: %s', resp)
            else:
                self.debug('S3 object deletion OK: %s', resp)
            self.new_func_process_data(storage, key, eid, attr)