adding log

tasks/upload_finisher.py

@@ -1,8 +1,7 @@
 import logging
 import re
-from copy import deepcopy
 
-import sentry_sdk
+from redis.exceptions import LockError
 from shared.celery_config import (
     compute_comparison_task_name,
     notify_task_name,
@@ -79,22 +78,40 @@
         commit = commits.first()
         assert commit, "Commit not found in database."
         redis_connection = get_redis_connection()
-        with redis_connection.lock(lock_name, timeout=60 * 5, blocking_timeout=5):
-            commit_yaml = UserYaml(commit_yaml)
-            db_session.commit()
-            commit.notified = False
-            db_session.commit()
-            result = await self.finish_reports_processing(
-                db_session,
-                commit,
-                commit_yaml,
-                processing_results,
-                report_code,
-                checkpoints,
+        try:
+            with redis_connection.lock(lock_name, timeout=60 * 5, blocking_timeout=5):
+                commit_yaml = UserYaml(commit_yaml)
+                db_session.commit()
+                commit.notified = False
+                db_session.commit()
+                result = await self.finish_reports_processing(
+                    db_session,
+                    commit,
+                    commit_yaml,
+                    processing_results,
+                    report_code,
+                    checkpoints,
+                )
+                save_commit_measurements(commit)
+                self.invalidate_caches(redis_connection, commit)
+                log.info(
+                    "Finished upload_finisher task",
+                    extra=dict(
+                        repoid=repoid,
+                        commit=commitid,
+                        parent_task=self.request.parent_id,
+                    ),
+                )
+                return result
+        except LockError:
+            log.warning(
+                "Unable to acquire lock for key %s. Retrying",
+                lock_name,
+                extra=dict(
+                    commit=commitid,
+                    repoid=repoid,
+                ),
             )
-            save_commit_measurements(commit)
-            self.invalidate_caches(redis_connection, commit)
-        return result
 
     async def finish_reports_processing(
         self,