Skip to content

Commit 28a7241

Browse files
committed
Add extra 1s wait for next CF invalidation request
1 parent 105e6c3 commit 28a7241

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

charon/cache.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,9 @@ def invalidate_paths(
113113
break
114114
if current_invalidation:
115115
results.append(current_invalidation)
116+
# To avoid conflict rushing request, we can wait 1s here
117+
# for next invalidation request sending.
118+
time.sleep(1)
116119
caller_ref = str(uuid.uuid4())
117120
logger.debug(
118121
"Processing invalidation for batch with ref %s, size: %s",

charon/pkgs/maven.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -459,7 +459,7 @@ def handle_maven_uploading(
459459
else:
460460
logger.info("Bypass indexing")
461461

462-
# Finally do the CF invalidating for metadata files
462+
# 11. Finally do the CF invalidating for metadata files
463463
if cf_enable and len(cf_invalidate_paths) > 0:
464464
cf_client = CFClient(aws_profile=aws_profile)
465465
cf_invalidate_paths = __wildcard_metadata_paths(cf_invalidate_paths)
@@ -639,6 +639,7 @@ def handle_maven_del(
639639
else:
640640
logger.info("Bypassing indexing")
641641

642+
# 9. Finally do the CF invalidating for metadata files
642643
if cf_enable and len(cf_invalidate_paths):
643644
cf_client = CFClient(aws_profile=aws_profile)
644645
cf_invalidate_paths = __wildcard_metadata_paths(cf_invalidate_paths)

0 commit comments

Comments
 (0)