diff --git a/swh/indexer/indexer.py b/swh/indexer/indexer.py --- a/swh/indexer/indexer.py +++ b/swh/indexer/indexer.py @@ -344,6 +344,9 @@ sentry_sdk.capture_exception() summary["status"] = "failed" return summary + else: + # Reset tag after we finished processing the given content + sentry_sdk.set_tag("swh-indexer-content-sha1", "") summary_persist = self.persist_index_computations(results) self.results = results @@ -406,6 +409,9 @@ self.log.exception("Problem when reading contents metadata.") sentry_sdk.capture_exception() summary["status"] = "failed" + else: + # Reset tag after we finished processing the given content + sentry_sdk.set_tag("swh-indexer-content-sha1", "") return summary @@ -493,6 +499,7 @@ continue sentry_sdk.set_tag("swh-indexer-content-sha1", sha1) yield from self.index(sha1, raw_content, **kwargs) + sentry_sdk.set_tag("swh-indexer-content-sha1", "") def _index_with_skipping_already_done( self, partition_id: int, nb_partitions: int @@ -642,6 +649,7 @@ for origin in origins: sentry_sdk.set_tag("swh-indexer-origin-url", origin.url) results.extend(self.index(origin.url, **kwargs)) + sentry_sdk.set_tag("swh-indexer-origin-url", "") return results @@ -710,6 +718,8 @@ self.log.exception("Problem when processing directory") sentry_sdk.capture_exception() summary["status"] = "failed" + else: + sentry_sdk.set_tag("swh-indexer-directory-swhid", "") summary_persist = self.persist_index_computations(results) if summary_persist: