@@ -4156,7 +4156,7 @@ def s3_repository(self):
41564156 return self ._s3_repo_instance
41574157
41584158 def _upload_image (self , image_path : str ):
4159- ProcessedImage = namedtuple ("ProcessedImage" , ["uploaded" , "path" , "entity" ])
4159+ ProcessedImage = namedtuple ("ProcessedImage" , ["uploaded" , "path" , "entity" , "name" ])
41604160 if self ._from_s3_bucket :
41614161 image_bytes = (
41624162 GetS3ImageUseCase (s3_bucket = self ._from_s3_bucket , image_path = image_path )
@@ -4177,9 +4177,9 @@ def _upload_image(self, image_path: str):
41774177
41784178 if not upload_response .errors and upload_response .data :
41794179 entity = upload_response .data
4180- return ProcessedImage (uploaded = True , path = entity .path , entity = entity )
4180+ return ProcessedImage (uploaded = True , path = entity .path , entity = entity , name = Path ( image_path ). name )
41814181 else :
4182- return ProcessedImage (uploaded = False , path = image_path , entity = None )
4182+ return ProcessedImage (uploaded = False , path = image_path , entity = None , name = Path ( image_path ). name )
41834183
41844184 @property
41854185 def paths (self ):
@@ -4277,7 +4277,7 @@ def execute(self):
42774277 if processed_image .uploaded and processed_image .entity :
42784278 uploaded_images .append (processed_image )
42794279 else :
4280- failed_images .append (processed_image )
4280+ failed_images .append (processed_image . path )
42814281 yield
42824282
42834283 uploaded = []
@@ -4293,6 +4293,7 @@ def execute(self):
42934293
42944294 attachments , duplications = response .data
42954295 uploaded .extend (attachments )
4296- # duplicates.extend(duplications)
4296+ uploaded = [image ["name" ] for image in uploaded ]
4297+ failed_images = [image .name for image in failed_images ]
42974298
4298- self .response .data = uploaded , failed_images , duplications
4299+ self ._response .data = uploaded , failed_images , duplications
0 commit comments