renamed run_id to service_run_id and RunID to ServiceRunID

Author: Andrei Neagu

packages/models-library/src/models_library/api_schemas_resource_usage_tracker/service_runs.py

@@ -8,13 +8,13 @@
 from ..projects_nodes_io import NodeID
 from ..resource_tracker import CreditTransactionStatus, ServiceRunStatus
 from ..services import ServiceKey, ServiceVersion
-from ..services_types import RunID
+from ..services_types import ServiceRunID
 from ..users import UserID
 from ..wallets import WalletID
 
 
 class ServiceRunGet(BaseModel):
-    service_run_id: RunID
+    service_run_id: ServiceRunID
     wallet_id: WalletID | None
     wallet_name: str | None
     user_id: UserID

packages/models-library/src/models_library/api_schemas_webserver/resource_usage.py

@@ -16,7 +16,7 @@
     UnitExtraInfo,
 )
 from ..services import ServiceKey, ServiceVersion
-from ..services_types import RunID
+from ..services_types import ServiceRunID
 from ..users import UserID
 from ..wallets import WalletID
 from ._base import InputSchema, OutputSchema
@@ -27,7 +27,7 @@
 class ServiceRunGet(
     BaseModel
 ):  # NOTE: this is already in use so I didnt modidy inheritance from OutputSchema
-    service_run_id: RunID
+    service_run_id: ServiceRunID
     wallet_id: WalletID | None
     wallet_name: str | None
     user_id: UserID

packages/models-library/src/models_library/rabbitmq_messages.py

@@ -15,7 +15,7 @@
 from .projects_state import RunningState
 from .services import ServiceKey, ServiceType, ServiceVersion
 from .services_resources import ServiceResourcesDict
-from .services_types import RunID
+from .services_types import ServiceRunID
 from .users import UserID
 from .utils.enums import StrAutoEnum
 from .wallets import WalletID
@@ -179,7 +179,7 @@ class RabbitResourceTrackingMessageType(StrAutoEnum):
 class RabbitResourceTrackingBaseMessage(RabbitMessageBase):
     channel_name: Literal["io.simcore.service.tracking"] = "io.simcore.service.tracking"
 
-    service_run_id: RunID = Field(
+    service_run_id: ServiceRunID = Field(
         ..., description="uniquely identitifies the service run"
     )
     created_at: datetime.datetime = Field(

packages/models-library/src/models_library/services.py

@@ -7,9 +7,9 @@
 from .services_metadata_published import ServiceInputsDict, ServiceMetaDataPublished
 from .services_types import (
     DynamicServiceKey,
-    RunID,
     ServiceKey,
     ServicePortKey,
+    ServiceRunID,
     ServiceVersion,
 )
 
@@ -21,14 +21,14 @@
     "BootOptions",
     "DynamicServiceKey",
     "LATEST_INTEGRATION_VERSION",
-    "RunID",
     "ServiceInput",
     "ServiceInputsDict",
     "ServiceKey",
     "ServiceKeyVersion",
     "ServiceMetaDataPublished",
     "ServiceOutput",
     "ServicePortKey",
+    "ServiceRunID",
     "ServiceType",
     "ServiceVersion",
 )

packages/models-library/src/models_library/services_types.py

@@ -45,7 +45,7 @@
 ServiceVersion: TypeAlias = Annotated[str, StringConstraints(pattern=SIMPLE_VERSION_RE)]
 
 
-class RunID(str):
+class ServiceRunID(str):
     """
     Used to assign a unique identifier to the run of a service.
 
@@ -92,7 +92,7 @@ def __get_pydantic_core_schema__(
         return core_schema.no_info_after_validator_function(cls, handler(str))
 
     @classmethod
-    def validate(cls, v: "RunID | str", _: ValidationInfo) -> "RunID":
+    def validate(cls, v: "ServiceRunID | str", _: ValidationInfo) -> "ServiceRunID":
         if isinstance(v, cls):
             return v
         if isinstance(v, str):

packages/models-library/tests/test_services_types.py

@@ -1,7 +1,7 @@
 import pytest
 from models_library.projects import ProjectID
 from models_library.projects_nodes import NodeID
-from models_library.services_types import RunID
+from models_library.services_types import ServiceRunID
 from models_library.users import UserID
 from pydantic import PositiveInt
 
@@ -25,12 +25,12 @@ def test_run_id_get_resource_tracking_run_id(
     iteration: PositiveInt,
     expected_result: str,
 ):
-    resource_tracking_run_id = RunID.get_resource_tracking_run_id(
+    resource_tracking_service_run_id = ServiceRunID.get_resource_tracking_run_id(
         user_id, project_id, node_id, iteration
     )
-    assert isinstance(resource_tracking_run_id, RunID)
-    assert resource_tracking_run_id == expected_result
+    assert isinstance(resource_tracking_service_run_id, ServiceRunID)
+    assert resource_tracking_service_run_id == expected_result
 
 
 def test_run_id_create_for_dynamic_sidecar():
-    assert isinstance(RunID.create_for_dynamic_sidecar(), RunID)
+    assert isinstance(ServiceRunID.create_for_dynamic_sidecar(), ServiceRunID)

packages/service-library/src/servicelib/rabbitmq/rpc_interfaces/webserver/licenses/licensed_items.py

@@ -8,7 +8,7 @@
 from models_library.licensed_items import LicensedItemID
 from models_library.products import ProductName
 from models_library.rabbitmq_basic_types import RPCMethodName
-from models_library.services_types import RunID
+from models_library.services_types import ServiceRunID
 from models_library.users import UserID
 from models_library.wallets import WalletID
 from pydantic import TypeAdapter
@@ -65,7 +65,7 @@ async def checkout_licensed_item_for_wallet(
     wallet_id: WalletID,
     licensed_item_id: LicensedItemID,
     num_of_seats: int,
-    service_run_id: RunID,
+    service_run_id: ServiceRunID,
 ) -> None:
     result = await rabbitmq_rpc_client.request(
         WEBSERVER_RPC_NAMESPACE,
@@ -89,7 +89,7 @@ async def release_licensed_item_for_wallet(
     wallet_id: WalletID,
     licensed_item_id: LicensedItemID,
     num_of_seats: int,
-    service_run_id: RunID,
+    service_run_id: ServiceRunID,
 ) -> None:
     result = await rabbitmq_rpc_client.request(
         WEBSERVER_RPC_NAMESPACE,

services/agent/src/simcore_service_agent/models/volumes.py

@@ -6,14 +6,14 @@
 )
 from models_library.projects import ProjectID
 from models_library.projects_nodes_io import NodeID
-from models_library.services_types import RunID
+from models_library.services_types import ServiceRunID
 from models_library.users import UserID
 from pydantic import BaseModel, ConfigDict, Field, TypeAdapter
 
 
 class DynamicServiceVolumeLabels(BaseModel):
     node_uuid: NodeID
-    run_id: RunID
+    run_id: ServiceRunID
     source: str
     study_id: ProjectID
     swarm_stack_name: str

services/agent/tests/unit/conftest.py

@@ -15,7 +15,7 @@
 from fastapi.testclient import TestClient
 from models_library.projects import ProjectID
 from models_library.projects_nodes_io import NodeID
-from models_library.services_types import RunID
+from models_library.services_types import ServiceRunID
 from models_library.users import UserID
 from pytest_simcore.helpers.monkeypatch_envs import EnvVarsDict, setenvs_from_dict
 from settings_library.rabbit import RabbitSettings
@@ -56,8 +56,8 @@ def test_client(initialized_app: FastAPI) -> TestClient:
 
 
 @pytest.fixture
-def run_id() -> RunID:
-    return RunID.create_for_dynamic_sidecar()
+def service_run_id() -> ServiceRunID:
+    return ServiceRunID.create_for_dynamic_sidecar()
 
 
 @pytest.fixture
@@ -77,7 +77,7 @@ def volumes_path(tmp_path: Path) -> Path:
 
 @pytest.fixture
 async def create_dynamic_sidecar_volume(
-    run_id: RunID,
+    service_run_id: ServiceRunID,
     project_id: ProjectID,
     swarm_stack_name: str,
     user_id: UserID,
@@ -89,13 +89,13 @@ async def create_dynamic_sidecar_volume(
     async with aiodocker.Docker() as docker_client:
 
         async def _(node_id: NodeID, in_use: bool, volume_name: str) -> str:
-            source = get_source(run_id, node_id, volumes_path / volume_name)
+            source = get_source(service_run_id, node_id, volumes_path / volume_name)
             volume = await docker_client.volumes.create(
                 {
                     "Name": source,
                     "Labels": {
                         "node_uuid": f"{node_id}",
-                        "run_id": run_id,
+                        "run_id": service_run_id,
                         "source": source,
                         "study_id": f"{project_id}",
                         "swarm_stack_name": swarm_stack_name,

services/agent/tests/unit/test_services_backup.py

@@ -11,7 +11,7 @@
 from fastapi import FastAPI
 from models_library.projects import ProjectID
 from models_library.projects_nodes_io import NodeID
-from models_library.services_types import RunID
+from models_library.services_types import ServiceRunID
 from pydantic import NonNegativeInt
 from simcore_service_agent.core.settings import ApplicationSettings
 from simcore_service_agent.services.backup import backup_volume
@@ -48,7 +48,7 @@ async def test_backup_volume(
     volume_content: Path,
     project_id: ProjectID,
     swarm_stack_name: str,
-    run_id: RunID,
+    service_run_id: ServiceRunID,
     downlaoded_from_s3: Path,
     create_dynamic_sidecar_volumes: Callable[[NodeID, bool], Awaitable[set[str]]],
     initialized_app: FastAPI,
@@ -80,7 +80,7 @@ async def test_backup_volume(
     async with session.client("s3", endpoint_url=f"{settings.AGENT_VOLUMES_CLEANUP_S3_ENDPOINT}") as s3_client:  # type: ignore
         list_response = await s3_client.list_objects_v2(
             Bucket=settings.AGENT_VOLUMES_CLEANUP_S3_BUCKET,
-            Prefix=f"{swarm_stack_name}/{project_id}/{node_id}/{run_id}",
+            Prefix=f"{swarm_stack_name}/{project_id}/{node_id}/{service_run_id}",
         )
         synced_keys: list[str] = [o["Key"] for o in list_response["Contents"]]