X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2dms%2Fservice%2Fnfdeployment_handler.py;fp=o2dms%2Fservice%2Fnfdeployment_handler.py;h=665e03e92d9c651ab9e6f9dd07e0addc67b6eefd;hb=5143e92a36bd2142e04d0d80dbc60d68c3da03d7;hp=c6a40fff801ec5accfd34f1570b8589147903bf6;hpb=a6392b46c7b808b8adeede97c4dd69c5032e0d11;p=pti%2Fo2.git diff --git a/o2dms/service/nfdeployment_handler.py b/o2dms/service/nfdeployment_handler.py index c6a40ff..665e03e 100644 --- a/o2dms/service/nfdeployment_handler.py +++ b/o2dms/service/nfdeployment_handler.py @@ -20,6 +20,7 @@ from o2dms.domain.dms import NfDeployment, NfDeploymentDesc from o2dms.domain import commands from typing import Callable +from o2dms.domain.exceptions import NfdeploymentNotFoundError from o2dms.domain import events from o2common.service.unit_of_work import AbstractUnitOfWork from helm_sdk import Helm @@ -82,15 +83,19 @@ def handle_nfdeployment_statechanged( # retry 10 seconds -@retry(tries=20, max_delay=10000) +@retry( + (NfdeploymentNotFoundError), + tries=100, + delay=2, max_delay=10000, backoff=1) def _retry_get_nfdeployment( cmd: commands.InstallNfDeployment, uow: AbstractUnitOfWork): nfdeployment: NfDeployment = uow.nfdeployments.get( cmd.NfDeploymentId) if nfdeployment is None: - raise Exception("Cannot find NfDeployment: {}".format( - cmd.NfDeploymentId)) + raise NfdeploymentNotFoundError( + "Cannot find NfDeployment: {}".format( + cmd.NfDeploymentId)) return nfdeployment