diff --git a/laborious/activities/activities.py b/laborious/activities/activities.py index 9a03f54..df78a08 100644 --- a/laborious/activities/activities.py +++ b/laborious/activities/activities.py @@ -164,6 +164,6 @@ class Activities(Storage, MLFlow, Gates, OPC, ModelMetrics, API): Storage.close(self) MLFlow.close(self) Gates.close(self) - await OPC.close(self) + await OPC.aclose(self) ModelMetrics.close(self) API.close(self) diff --git a/laborious/activities/opc.py b/laborious/activities/opc.py index be5a941..04ed18e 100644 --- a/laborious/activities/opc.py +++ b/laborious/activities/opc.py @@ -491,7 +491,7 @@ class OPC(SientiaMonitoring): return data.to_dict() - async def close(self): + async def aclose(self): """ Gracefully shutdown all OPC server connections and cleanup resources. diff --git a/tests/laborious/activities/test_opc.py b/tests/laborious/activities/test_opc.py index c2d37dd..6a36f8a 100644 --- a/tests/laborious/activities/test_opc.py +++ b/tests/laborious/activities/test_opc.py @@ -734,5 +734,5 @@ async def test_validate_server(opc): @mark.asyncio async def test_close(opc): opc.opc_repository['server1'].disconnect = AsyncMock(return_value=True) - await opc.close() + await opc.aclose() opc.opc_repository['server1'].disconnect.assert_called_once()