diff --git a/charon/cache.py b/charon/cache.py index 652fe8b6..5dd103d4 100644 --- a/charon/cache.py +++ b/charon/cache.py @@ -113,6 +113,9 @@ def invalidate_paths( break if current_invalidation: results.append(current_invalidation) + # To avoid conflict rushing request, we can wait 1s here + # for next invalidation request sending. + time.sleep(1) caller_ref = str(uuid.uuid4()) logger.debug( "Processing invalidation for batch with ref %s, size: %s", diff --git a/charon/pkgs/maven.py b/charon/pkgs/maven.py index c7413c80..f8ba8abc 100644 --- a/charon/pkgs/maven.py +++ b/charon/pkgs/maven.py @@ -459,7 +459,7 @@ def handle_maven_uploading( else: logger.info("Bypass indexing") - # Finally do the CF invalidating for metadata files + # 11. Finally do the CF invalidating for metadata files if cf_enable and len(cf_invalidate_paths) > 0: cf_client = CFClient(aws_profile=aws_profile) cf_invalidate_paths = __wildcard_metadata_paths(cf_invalidate_paths) @@ -639,6 +639,7 @@ def handle_maven_del( else: logger.info("Bypassing indexing") + # 9. Finally do the CF invalidating for metadata files if cf_enable and len(cf_invalidate_paths): cf_client = CFClient(aws_profile=aws_profile) cf_invalidate_paths = __wildcard_metadata_paths(cf_invalidate_paths)