diff options
author | Lukasz Rajewski <lukasz.rajewski@t-mobile.pl> | 2024-03-04 20:14:02 +0100 |
---|---|---|
committer | Lukasz Rajewski <lukasz.rajewski@t-mobile.pl> | 2024-03-07 10:09:40 +0100 |
commit | 7c3de7ac0ff93bae27f2a0a30198bb3d2e24cbf1 (patch) | |
tree | 5ef0ae6191357a05e4766fc95a6e29d517b4767c /src | |
parent | 04804c49eefd80efb0f31b27b56192ee4c77081b (diff) |
Add retry option to onap_service
Add retry option to onap_service
Issue-ID: TEST-404
Signed-off-by: Lukasz Rajewski <lukasz.rajewski@t-mobile.pl>
Change-Id: Ib86ad8faed3a89786054ab49eeb58f4cc46471fb
Diffstat (limited to 'src')
-rw-r--r-- | src/onapsdk/configuration/global_settings.py | 2 | ||||
-rw-r--r-- | src/onapsdk/onap_service.py | 5 |
2 files changed, 5 insertions, 2 deletions
diff --git a/src/onapsdk/configuration/global_settings.py b/src/onapsdk/configuration/global_settings.py index 7c09187..8bfea14 100644 --- a/src/onapsdk/configuration/global_settings.py +++ b/src/onapsdk/configuration/global_settings.py @@ -74,6 +74,8 @@ PLATFORM = "Onapsdk_platform" DEFAULT_REQUEST_TIMEOUT = 60 +DEFAULT_REQUEST_RETRIES = 10 + # SDC DISTRIBUTION SDC_SERVICE_DISTRIBUTION_COMPONENTS = [ "SO-sdc-controller", diff --git a/src/onapsdk/onap_service.py b/src/onapsdk/onap_service.py index 566c9bc..fffc2b2 100644 --- a/src/onapsdk/onap_service.py +++ b/src/onapsdk/onap_service.py @@ -126,6 +126,7 @@ class OnapService(ABC): basic_auth: Dict[str, str] = kwargs.pop('basic_auth', None) exception = kwargs.pop('exception', None) timeout = kwargs.pop('timeout', None) + retries = kwargs.pop('retries', settings.DEFAULT_REQUEST_RETRIES) if method == "PATCH": headers = kwargs.pop('headers', cls.patch_headers).copy() else: @@ -136,7 +137,7 @@ class OnapService(ABC): data = kwargs.get('data', None) try: # build the request with the requested method - session = cls.__requests_retry_session(timeout=timeout) + session = cls.__requests_retry_session(retries=retries, timeout=timeout) if cert: session.cert = cert OnapService._set_basic_auth_if_needed(basic_auth, session) @@ -257,7 +258,7 @@ class OnapService(ABC): raise exception @staticmethod - def __requests_retry_session(retries: int = 10, + def __requests_retry_session(retries: int = settings.DEFAULT_REQUEST_RETRIES, backoff_factor: float = 0.3, session: requests.Session = None, timeout: int = None |