Add mutex lock file to registry CLI wrapper class
All checks were successful
Lint Checks / Run linter (pull_request) Successful in 44s
Deploy Test / Run deploy test suite (pull_request) Successful in 4m57s
K8s Deploy Test / Run deploy test suite on kind/k8s (pull_request) Successful in 8m22s
K8s Deployment Control Test / Run deployment control suite on kind/k8s (pull_request) Successful in 5m51s
Webapp Test / Run webapp test suite (pull_request) Successful in 5m6s
Smoke Test / Run basic test suite (pull_request) Successful in 4m36s

This commit is contained in:
Prathamesh Musale 2024-10-24 15:43:32 +05:30
parent 4a7df2de33
commit ed4ed48375
2 changed files with 3 additions and 2 deletions

View File

@ -10,7 +10,7 @@ def registry_mutex():
@wraps(func)
def wrapper(self, *args, **kwargs):
lock_file_path = DEFAULT_LOCK_FILE_PATH
if self.mutex_lock_file is not None:
if self.mutex_lock_file:
lock_file_path = self.mutex_lock_file
with open(lock_file_path, 'w') as lock_file:

View File

@ -114,9 +114,10 @@ def is_id(name_or_id: str):
class LaconicRegistryClient:
def __init__(self, config_file, log_file=None):
def __init__(self, config_file, log_file=None, mutex_lock_file=None):
self.config_file = config_file
self.log_file = log_file
self.mutex_lock_file = mutex_lock_file
self.cache = AttrDict(
{
"name_or_id": {},