From 428d946c7504c7fa0ade5a024267a70d20fcfac5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Taneli=20Lepp=C3=A4?= <taneli@google.com>
Date: Sat, 11 Nov 2023 13:40:39 +0100
Subject: [PATCH] Fix concurrency deferring.

---
 main.py | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/main.py b/main.py
index a4675ec..7109149 100644
--- a/main.py
+++ b/main.py
@@ -497,7 +497,7 @@ def handle_concurrency_post(logger, concurrency_config, jinja_environment,
 
     bucket = storage_client.bucket(concurrency_bucket)
     concurrency_blob = bucket.blob(concurrency_file)
-    concurrency_blob.delete()
+    # concurrency_blob.delete()
 
 
 def handle_concurrency_pre(logger, concurrency_config, jinja_environment,
@@ -554,12 +554,12 @@ def handle_concurrency_pre(logger, concurrency_config, jinja_environment,
                         'process_earliest': concurrency_earliest,
                         'blob_time_created': concurrency_blob.time_created
                     })
-                return False
-        logger.info('Concurrency lock file exists, not processing the message.',
-                    extra={
-                        'bucket': concurrency_bucket,
-                        'blob': concurrency_file
-                    })
+        else:
+            logger.info('Concurrency lock file exists, not processing the message.',
+                        extra={
+                            'bucket': concurrency_bucket,
+                            'blob': concurrency_file
+                        })
         if 'defer' in concurrency_config and concurrency_config['defer']:
             raise ConcurrencyRetryException('Failing message processing due to concurrency control, allowing retry.')
         return False