@@ -4159,7 +4159,7 @@ def s3_repository(self):
41594159 return self ._s3_repo_instance
41604160
41614161 def _upload_image (self , image_path : str ):
4162- ProcessedImage = namedtuple ("ProcessedImage" , ["uploaded" , "path" , "entity" ])
4162+ ProcessedImage = namedtuple ("ProcessedImage" , ["uploaded" , "path" , "entity" , "name" ])
41634163 if self ._from_s3_bucket :
41644164 image_bytes = (
41654165 GetS3ImageUseCase (s3_bucket = self ._from_s3_bucket , image_path = image_path )
@@ -4180,9 +4180,9 @@ def _upload_image(self, image_path: str):
41804180
41814181 if not upload_response .errors and upload_response .data :
41824182 entity = upload_response .data
4183- return ProcessedImage (uploaded = True , path = entity .path , entity = entity )
4183+ return ProcessedImage (uploaded = True , path = entity .path , entity = entity , name = Path ( image_path ). name )
41844184 else :
4185- return ProcessedImage (uploaded = False , path = image_path , entity = None )
4185+ return ProcessedImage (uploaded = False , path = image_path , entity = None , name = Path ( image_path ). name )
41864186
41874187 @property
41884188 def paths (self ):
@@ -4280,7 +4280,7 @@ def execute(self):
42804280 if processed_image .uploaded and processed_image .entity :
42814281 uploaded_images .append (processed_image )
42824282 else :
4283- failed_images .append (processed_image )
4283+ failed_images .append (processed_image . path )
42844284 yield
42854285
42864286 uploaded = []
@@ -4296,6 +4296,7 @@ def execute(self):
42964296
42974297 attachments , duplications = response .data
42984298 uploaded .extend (attachments )
4299- # duplicates.extend(duplications)
4299+ uploaded = [image ["name" ] for image in uploaded ]
4300+ failed_images = [image .name for image in failed_images ]
43004301
4301- self .response .data = uploaded , failed_images , duplications
4302+ self ._response .data = uploaded , failed_images , duplications
0 commit comments