refactor(BA-5837): propagate my_bulk_* rename + BEP cleanup to ValkeyCache surface

Carry the stack-wide `bulk_create_my` / `bulk_update_my` →
`my_bulk_create` / `my_bulk_update` rename through the cache_source
module added by this PR, plus the GQL / adapter / DTO touchpoints that
the rebase resolved with `-X theirs` (which kept stale identifiers).

Also strip the residual `BEP-1052 §X` references from the cache_source
docstring and the merged-view repository docstring. Only the news
fragments retain the BEP wording.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: jopemachine

src/ai/backend/common/dto/manager/v2/app_config/__init__.py

@@ -11,9 +11,9 @@
 )
 from .response import (
     AppConfigNode,
-    BulkCreateMyAppConfigFragmentsPayload,
-    BulkUpdateMyAppConfigFragmentsPayload,
     GetUserAppConfigPayload,
+    MyBulkCreateAppConfigFragmentsPayload,
+    MyBulkUpdateAppConfigFragmentsPayload,
     SearchAppConfigsPayload,
 )
 from .types import (
@@ -28,8 +28,8 @@
     "AppConfigOrder",
     "AppConfigOrderField",
     "AppConfigScopeType",
-    "BulkCreateMyAppConfigFragmentsPayload",
-    "BulkUpdateMyAppConfigFragmentsPayload",
+    "MyBulkCreateAppConfigFragmentsPayload",
+    "MyBulkUpdateAppConfigFragmentsPayload",
     "GetUserAppConfigInput",
     "GetUserAppConfigPayload",
     "OrderDirection",

src/ai/backend/common/dto/manager/v2/app_config/response.py

@@ -17,8 +17,8 @@
 
 __all__ = (
     "AppConfigNode",
-    "BulkCreateMyAppConfigFragmentsPayload",
-    "BulkUpdateMyAppConfigFragmentsPayload",
+    "MyBulkCreateAppConfigFragmentsPayload",
+    "MyBulkUpdateAppConfigFragmentsPayload",
     "GetUserAppConfigPayload",
     "SearchAppConfigsPayload",
 )
@@ -62,8 +62,8 @@ class SearchAppConfigsPayload(BaseResponseModel):
     has_previous_page: bool = Field(default=False, description="Whether there is a previous page.")
 
 
-class BulkCreateMyAppConfigFragmentsPayload(BaseResponseModel):
-    """Payload for `bulkCreateMyAppConfigFragments`.
+class MyBulkCreateAppConfigFragmentsPayload(BaseResponseModel):
+    """Payload for `myBulkCreateAppConfigFragments`.
 
     Each successfully created row produces a recomputed merged
     `AppConfigNode`; failures are collected per-item.
@@ -75,8 +75,8 @@ class BulkCreateMyAppConfigFragmentsPayload(BaseResponseModel):
     failed: list[AppConfigFragmentBulkError] = Field(description="Per-item failures.")
 
 
-class BulkUpdateMyAppConfigFragmentsPayload(BaseResponseModel):
-    """Payload for `bulkUpdateMyAppConfigFragments`."""
+class MyBulkUpdateAppConfigFragmentsPayload(BaseResponseModel):
+    """Payload for `myBulkUpdateAppConfigFragments`."""
 
     updated: list[AppConfigNode] = Field(
         description="Recomputed merged AppConfig views for each updated USER fragment.",

src/ai/backend/manager/api/adapters/app_config.py

@@ -19,15 +19,15 @@
 )
 from ai.backend.common.dto.manager.v2.app_config.response import (
     AppConfigNode,
-    BulkCreateMyAppConfigFragmentsPayload,
-    BulkUpdateMyAppConfigFragmentsPayload,
     GetUserAppConfigPayload,
+    MyBulkCreateAppConfigFragmentsPayload,
+    MyBulkUpdateAppConfigFragmentsPayload,
     SearchAppConfigsPayload,
 )
 from ai.backend.common.dto.manager.v2.app_config.types import AppConfigOrderField, OrderDirection
 from ai.backend.common.dto.manager.v2.app_config_fragment.request import (
-    BulkCreateMyAppConfigFragmentsInput,
-    BulkUpdateMyAppConfigFragmentsInput,
+    MyBulkCreateAppConfigFragmentsInput,
+    MyBulkUpdateAppConfigFragmentsInput,
 )
 from ai.backend.common.dto.manager.v2.app_config_fragment.response import (
     AppConfigFragmentBulkError,
@@ -52,15 +52,15 @@
 from ai.backend.manager.services.app_config_fragment.actions.admin_search_app_configs import (
     AdminSearchAppConfigsAction,
 )
-from ai.backend.manager.services.app_config_fragment.actions.bulk_create_my import (
-    BulkCreateMyAppConfigFragmentsAction,
-)
-from ai.backend.manager.services.app_config_fragment.actions.bulk_update_my import (
-    BulkUpdateMyAppConfigFragmentsAction,
-)
 from ai.backend.manager.services.app_config_fragment.actions.get_user_app_config import (
     GetUserAppConfigAction,
 )
+from ai.backend.manager.services.app_config_fragment.actions.my_bulk_create import (
+    MyBulkCreateAppConfigFragmentsAction,
+)
+from ai.backend.manager.services.app_config_fragment.actions.my_bulk_update import (
+    MyBulkUpdateAppConfigFragmentsAction,
+)
 from ai.backend.manager.services.app_config_fragment.actions.search_user_app_configs import (
     SearchUserAppConfigsAction,
 )
@@ -154,33 +154,33 @@ async def admin_search_app_configs(
     # reasons travel back through the per-item `failed` list.
 
     async def my_bulk_create(
-        self, input: BulkCreateMyAppConfigFragmentsInput
-    ) -> BulkCreateMyAppConfigFragmentsPayload:
+        self, input: MyBulkCreateAppConfigFragmentsInput
+    ) -> MyBulkCreateAppConfigFragmentsPayload:
         items = [
             MyAppConfigFragmentBulkItem(name=item.name, extra_config=dict(item.extra_config))
             for item in input.items
         ]
-        wrapper = await self._processors.app_config_fragment.bulk_create_my.wait_for_complete(
-            BulkCreateMyAppConfigFragmentsAction(entity_ids=[], items=items)
+        wrapper = await self._processors.app_config_fragment.my_bulk_create.wait_for_complete(
+            MyBulkCreateAppConfigFragmentsAction(entity_ids=[], items=items)
         )
         result = wrapper.result
-        return BulkCreateMyAppConfigFragmentsPayload(
+        return MyBulkCreateAppConfigFragmentsPayload(
             created=[self._data_to_dto(item) for item in result.created],
             failed=[self._bulk_error_to_dto(err) for err in result.failed],
         )
 
     async def my_bulk_update(
-        self, input: BulkUpdateMyAppConfigFragmentsInput
-    ) -> BulkUpdateMyAppConfigFragmentsPayload:
+        self, input: MyBulkUpdateAppConfigFragmentsInput
+    ) -> MyBulkUpdateAppConfigFragmentsPayload:
         items = [
             MyAppConfigFragmentBulkItem(name=item.name, extra_config=dict(item.extra_config))
             for item in input.items
         ]
-        wrapper = await self._processors.app_config_fragment.bulk_update_my.wait_for_complete(
-            BulkUpdateMyAppConfigFragmentsAction(entity_ids=[], items=items)
+        wrapper = await self._processors.app_config_fragment.my_bulk_update.wait_for_complete(
+            MyBulkUpdateAppConfigFragmentsAction(entity_ids=[], items=items)
         )
         result = wrapper.result
-        return BulkUpdateMyAppConfigFragmentsPayload(
+        return MyBulkUpdateAppConfigFragmentsPayload(
             updated=[self._data_to_dto(item) for item in result.updated],
             failed=[self._bulk_error_to_dto(err) for err in result.failed],
         )

src/ai/backend/manager/api/adapters/app_config_fragment.py

@@ -32,7 +32,6 @@
 from ai.backend.common.dto.manager.v2.app_config_fragment.types import (
     AppConfigScopeType as DTOAppConfigScopeType,
 )
-from ai.backend.common.dto.manager.v2.app_config_fragment.types import OrderDirection
 from ai.backend.manager.api.adapter_options.pagination.pagination import PaginationSpec
 from ai.backend.manager.data.app_config_fragment.bulk_types import (
     AppConfigFragmentBulkItem,

src/ai/backend/manager/api/gql/app_config/types/__init__.py

@@ -1,6 +1,6 @@
 from .bulk_payloads import (
-    BulkCreateMyAppConfigFragmentsPayloadGQL,
-    BulkUpdateMyAppConfigFragmentsPayloadGQL,
+    MyBulkCreateAppConfigFragmentsPayloadGQL,
+    MyBulkUpdateAppConfigFragmentsPayloadGQL,
 )
 from .filters import (
     AppConfigFilterGQL,
@@ -14,6 +14,6 @@
     "AppConfigGQL",
     "AppConfigOrderByGQL",
     "AppConfigOrderFieldGQL",
-    "BulkCreateMyAppConfigFragmentsPayloadGQL",
-    "BulkUpdateMyAppConfigFragmentsPayloadGQL",
+    "MyBulkCreateAppConfigFragmentsPayloadGQL",
+    "MyBulkUpdateAppConfigFragmentsPayloadGQL",
 ]

src/ai/backend/manager/api/gql/app_config/types/bulk_payloads.py

@@ -3,10 +3,10 @@
 from __future__ import annotations
 
 from ai.backend.common.dto.manager.v2.app_config.response import (
-    BulkCreateMyAppConfigFragmentsPayload as BulkCreateMyPayloadDTO,
+    MyBulkCreateAppConfigFragmentsPayload as MyBulkCreatePayloadDTO,
 )
 from ai.backend.common.dto.manager.v2.app_config.response import (
-    BulkUpdateMyAppConfigFragmentsPayload as BulkUpdateMyPayloadDTO,
+    MyBulkUpdateAppConfigFragmentsPayload as MyBulkUpdatePayloadDTO,
 )
 from ai.backend.common.meta.meta import NEXT_RELEASE_VERSION
 from ai.backend.manager.api.gql.app_config.types.node import AppConfigGQL
@@ -24,12 +24,12 @@
 @gql_pydantic_type(
     BackendAIGQLMeta(
         added_version=NEXT_RELEASE_VERSION,
-        description="Payload for `bulkCreateMyAppConfigFragments` (recomputed views).",
+        description="Payload for `myBulkCreateAppConfigFragments` (recomputed views).",
     ),
-    model=BulkCreateMyPayloadDTO,
-    name="BulkCreateMyAppConfigFragmentsPayload",
+    model=MyBulkCreatePayloadDTO,
+    name="MyBulkCreateAppConfigFragmentsPayload",
 )
-class BulkCreateMyAppConfigFragmentsPayloadGQL(PydanticOutputMixin[BulkCreateMyPayloadDTO]):
+class MyBulkCreateAppConfigFragmentsPayloadGQL(PydanticOutputMixin[MyBulkCreatePayloadDTO]):
     created: list[AppConfigGQL] = gql_field(
         description="Recomputed merged AppConfig views for each created USER fragment.",
     )
@@ -41,12 +41,12 @@ class BulkCreateMyAppConfigFragmentsPayloadGQL(PydanticOutputMixin[BulkCreateMyP
 @gql_pydantic_type(
     BackendAIGQLMeta(
         added_version=NEXT_RELEASE_VERSION,
-        description="Payload for `bulkUpdateMyAppConfigFragments` (recomputed views).",
+        description="Payload for `myBulkUpdateAppConfigFragments` (recomputed views).",
     ),
-    model=BulkUpdateMyPayloadDTO,
-    name="BulkUpdateMyAppConfigFragmentsPayload",
+    model=MyBulkUpdatePayloadDTO,
+    name="MyBulkUpdateAppConfigFragmentsPayload",
 )
-class BulkUpdateMyAppConfigFragmentsPayloadGQL(PydanticOutputMixin[BulkUpdateMyPayloadDTO]):
+class MyBulkUpdateAppConfigFragmentsPayloadGQL(PydanticOutputMixin[MyBulkUpdatePayloadDTO]):
     updated: list[AppConfigGQL] = gql_field(
         description="Recomputed merged AppConfig views for each updated USER fragment.",
     )

src/ai/backend/manager/api/gql/app_config_fragment/__init__.py

@@ -6,8 +6,8 @@
     admin_bulk_purge_app_config_fragments,
     admin_bulk_update_app_config_fragments,
     app_config_fragment,
-    bulk_create_my_app_config_fragments,
-    bulk_update_my_app_config_fragments,
+    my_bulk_create_app_config_fragments,
+    my_bulk_update_app_config_fragments,
 )
 from .types import (
     AppConfigFragmentFilterGQL,
@@ -26,8 +26,8 @@
     "admin_bulk_create_app_config_fragments",
     "admin_bulk_update_app_config_fragments",
     "admin_bulk_purge_app_config_fragments",
-    "bulk_create_my_app_config_fragments",
-    "bulk_update_my_app_config_fragments",
+    "my_bulk_create_app_config_fragments",
+    "my_bulk_update_app_config_fragments",
     # Types
     "AppConfigFragmentGQL",
     "AppConfigScopeTypeGQL",

src/ai/backend/manager/api/gql/app_config_fragment/resolver/__init__.py

@@ -2,8 +2,8 @@
     admin_bulk_create_app_config_fragments,
     admin_bulk_purge_app_config_fragments,
     admin_bulk_update_app_config_fragments,
-    bulk_create_my_app_config_fragments,
-    bulk_update_my_app_config_fragments,
+    my_bulk_create_app_config_fragments,
+    my_bulk_update_app_config_fragments,
 )
 from .query import (
     admin_app_config_fragments,
@@ -16,6 +16,6 @@
     "admin_bulk_purge_app_config_fragments",
     "admin_bulk_update_app_config_fragments",
     "app_config_fragment",
-    "bulk_create_my_app_config_fragments",
-    "bulk_update_my_app_config_fragments",
+    "my_bulk_create_app_config_fragments",
+    "my_bulk_update_app_config_fragments",
 ]

src/ai/backend/manager/api/gql/app_config_fragment/resolver/mutation.py

@@ -6,8 +6,8 @@
 
 from ai.backend.common.meta.meta import NEXT_RELEASE_VERSION
 from ai.backend.manager.api.gql.app_config.types import (
-    BulkCreateMyAppConfigFragmentsPayloadGQL,
-    BulkUpdateMyAppConfigFragmentsPayloadGQL,
+    MyBulkCreateAppConfigFragmentsPayloadGQL,
+    MyBulkUpdateAppConfigFragmentsPayloadGQL,
 )
 from ai.backend.manager.api.gql.app_config_fragment.types import (
     AdminBulkCreateAppConfigFragmentInputGQL,
@@ -16,8 +16,8 @@
     AdminBulkPurgeAppConfigFragmentsPayloadGQL,
     AdminBulkUpdateAppConfigFragmentInputGQL,
     AdminBulkUpdateAppConfigFragmentsPayloadGQL,
-    BulkCreateMyAppConfigFragmentInputGQL,
-    BulkUpdateMyAppConfigFragmentInputGQL,
+    MyBulkCreateAppConfigFragmentInputGQL,
+    MyBulkUpdateAppConfigFragmentInputGQL,
 )
 from ai.backend.manager.api.gql.decorators import (
     BackendAIGQLMeta,
@@ -87,12 +87,12 @@ async def admin_bulk_purge_app_config_fragments(
         ),
     )
 )
-async def bulk_create_my_app_config_fragments(
+async def my_bulk_create_app_config_fragments(
     info: Info[StrawberryGQLContext],
-    input: BulkCreateMyAppConfigFragmentInputGQL,
-) -> BulkCreateMyAppConfigFragmentsPayloadGQL:
+    input: MyBulkCreateAppConfigFragmentInputGQL,
+) -> MyBulkCreateAppConfigFragmentsPayloadGQL:
     result = await info.context.adapters.app_config.my_bulk_create(input.to_pydantic())
-    return BulkCreateMyAppConfigFragmentsPayloadGQL.from_pydantic(result)
+    return MyBulkCreateAppConfigFragmentsPayloadGQL.from_pydantic(result)
 
 
 @gql_mutation(
@@ -104,9 +104,9 @@ async def bulk_create_my_app_config_fragments(
         ),
     )
 )
-async def bulk_update_my_app_config_fragments(
+async def my_bulk_update_app_config_fragments(
     info: Info[StrawberryGQLContext],
-    input: BulkUpdateMyAppConfigFragmentInputGQL,
-) -> BulkUpdateMyAppConfigFragmentsPayloadGQL:
+    input: MyBulkUpdateAppConfigFragmentInputGQL,
+) -> MyBulkUpdateAppConfigFragmentsPayloadGQL:
     result = await info.context.adapters.app_config.my_bulk_update(input.to_pydantic())
-    return BulkUpdateMyAppConfigFragmentsPayloadGQL.from_pydantic(result)
+    return MyBulkUpdateAppConfigFragmentsPayloadGQL.from_pydantic(result)

src/ai/backend/manager/api/gql/app_config_fragment/types/__init__.py

@@ -3,9 +3,9 @@
     AdminBulkCreateAppConfigFragmentInputGQL,
     AdminBulkPurgeAppConfigFragmentInputGQL,
     AdminBulkUpdateAppConfigFragmentInputGQL,
-    BulkCreateMyAppConfigFragmentInputGQL,
-    BulkUpdateMyAppConfigFragmentInputGQL,
     MyAppConfigFragmentItemInputGQL,
+    MyBulkCreateAppConfigFragmentInputGQL,
+    MyBulkUpdateAppConfigFragmentInputGQL,
 )
 from .bulk_payloads import (
     AdminBulkCreateAppConfigFragmentsPayloadGQL,
@@ -37,8 +37,8 @@
     "AppConfigFragmentOrderByGQL",
     "AppConfigFragmentOrderFieldGQL",
     "AppConfigScopeTypeGQL",
-    "BulkCreateMyAppConfigFragmentInputGQL",
-    "BulkUpdateMyAppConfigFragmentInputGQL",
+    "MyBulkCreateAppConfigFragmentInputGQL",
+    "MyBulkUpdateAppConfigFragmentInputGQL",
     "MyAppConfigFragmentItemInputGQL",
     "PurgeAppConfigFragmentKeyGQL",
 ]