X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_common%2Ftemporal%2Factivities%2Fvnf.py;h=2666f2b119e78619bea76b26dcbd45a0893fdef2;hb=e56853bb52d463573442303231094c1d109027f5;hp=0c5b22e2fadb469ee65ed317e0aa54dd23ce6e33;hpb=63c7ce8974a2d4ae295b5d61a81386bf6af734f2;p=osm%2Fcommon.git diff --git a/osm_common/temporal/activities/vnf.py b/osm_common/temporal/activities/vnf.py index 0c5b22e..2666f2b 100644 --- a/osm_common/temporal/activities/vnf.py +++ b/osm_common/temporal/activities/vnf.py @@ -417,3 +417,94 @@ class SetVnfModel(BaseActivity): async def __call__(self, activity_input: Input) -> None: raise NotImplementedError() + + +class GetModelNames(BaseActivity): + """Gets the models of VNFs associated with the NS. + + Collaborators: + DB read: vnfrs + + Raises (retryable): + DbException: If DB read operations fail + + Activity Lifecycle: + This activity should complete relatively quickly (less than a second). + + This activity will not report a heartbeat due to its + short-running nature. + + This is an idempotent activity. + """ + + @dataclass + class Input: + """ + Attributes: + ----------- + ns_uuid : str + The UUID of the NS from which we are looking for the model names. + """ + + ns_uuid: str + + @dataclass + class Output: + """ + Attributes: + ----------- + model_names: set[str] + The set of model names associated with the NS. + """ + + model_names: set[str] + + def __init__(self, db: DbBase): + super().__init__() + self.db: DbBase = db + + async def __call__(self, activity_input: Input) -> Output: + raise NotImplementedError() + + +class DeleteVnfRecord(BaseActivity): + """Delete a VNF record from DB. + + Collaborators: + DB Write: vnfrs + + Raises (retryable): + DbException: If DB access fails, the collection does not exist. + + Activity Lifecycle: + This activity should complete relatively quickly (less than a + second). However, it would be reasonable to wait up to 10 + seconds. + + This activity will not report a heartbeat due to its + short-running nature. + + This operation is idempotent. + + """ + + @dataclass + class Input: + """ + Input dataclass for activity that deletes a VNF record. + + Attributes: + ----------- + vnfr_uuid : str + The UUID of the VNF to be deleted from the vnfrs + collection in Mongo. + """ + + vnfr_uuid: str + + def __init__(self, db: DbBase): + super().__init__() + self.db: DbBase = db + + async def __call__(self, activity_input: Input) -> None: + raise NotImplementedError()