diff --git a/arkindex_worker/worker/__init__.py b/arkindex_worker/worker/__init__.py index fccde23bb123dd11c42198e51c705b784e493813..c4c88a1050074bf4c344b812071acd44b619fa61 100644 --- a/arkindex_worker/worker/__init__.py +++ b/arkindex_worker/worker/__init__.py @@ -149,11 +149,8 @@ class ElementsWorker( self.update_activity(element.id, ActivityState.Processed) except Exception as e: failed += 1 - element_id = ( - element.id - if isinstance(element, (Element, CachedElement)) - else item - ) + # Handle the case where we failed retrieving the element + element_id = element.id if element else item if isinstance(e, ErrorResponse): message = f"An API error occurred while processing element {element_id}: {e.title} - {e.content}" @@ -164,7 +161,8 @@ class ElementsWorker( message, exc_info=e if self.args.verbose else None, ) - self.update_activity(element_id, ActivityState.Error) + if element: + self.update_activity(element.id, ActivityState.Error) self.report.error(element_id, e) # Save report as local artifact