Merge branch 'master' into asyncio-executor

# Conflicts:
#	hazelcast/internal/asyncio_client.py

Author: yuce

.github/workflows/coverage_runner.yml

@@ -26,9 +26,8 @@ jobs:
         id: composite
         uses: hazelcast/hazelcast-tpm/membership@main
         with:
-          organization-name: 'hazelcast'
           member-name: ${{ github.actor }}
-          token: ${{ secrets.PAT }}
+          token: ${{ secrets.GH_TOKEN }}
 
   python-versions:
     uses: ./.github/workflows/get-python-versions.yml

.github/workflows/nightly_runner.yml

@@ -43,10 +43,15 @@ jobs:
         with:
           secret-ids: |
             HAZELCAST_ENTERPRISE_KEY,CN/HZ_LICENSE_KEY
+      - uses: hazelcast/docker-actions/get-jfrog-credentials@master
+        id: jfrog
+        with:
+          aws-role-to-assume: ${{ secrets.AWS_HAZELCAST_OIDC_GITHUB_ACTIONS_ROLE_ARN }}
+          jfrog-oidc-provider-name: ${{ github.repository_owner }}-snapshot-internal
       - name: Run tests
         env:
-          HZ_SNAPSHOT_INTERNAL_USERNAME: ${{ secrets.HZ_SNAPSHOT_INTERNAL_USERNAME }}
-          HZ_SNAPSHOT_INTERNAL_PASSWORD: ${{ secrets.HZ_SNAPSHOT_INTERNAL_PASSWORD }}
+          HZ_SNAPSHOT_INTERNAL_USERNAME: ${{ steps.jfrog.outputs.user }}
+          HZ_SNAPSHOT_INTERNAL_PASSWORD: ${{ steps.jfrog.outputs.token }}
         run: python run_tests.py
       - name: Upload remote controller logs on test failure
         uses: actions/upload-artifact@v4

hazelcast/internal/asyncio_client.py

@@ -7,7 +7,7 @@
 from hazelcast.internal.asyncio_compact import CompactSchemaService
 from hazelcast.config import Config, IndexConfig
 from hazelcast.internal.asyncio_connection import ConnectionManager, DefaultAsyncioAddressProvider
-from hazelcast.core import DistributedObjectEvent, DistributedObjectInfo
+from hazelcast.core import DistributedObjectEvent
 from hazelcast.discovery import HazelcastCloudAddressProvider
 from hazelcast.errors import IllegalStateError, InvalidConfigurationError
 from hazelcast.internal.asyncio_invocation import InvocationService, Invocation
@@ -18,14 +18,14 @@
 from hazelcast.internal.asyncio_partition import PartitionService, InternalPartitionService
 from hazelcast.protocol.codec import (
     client_add_distributed_object_listener_codec,
-    client_get_distributed_objects_codec,
     client_remove_distributed_object_listener_codec,
     dynamic_config_add_vector_collection_config_codec,
 )
 from hazelcast.internal.asyncio_proxy.manager import (
     EXECUTOR_SERVICE,
     LIST_SERVICE,
     MAP_SERVICE,
+    MULTI_MAP_SERVICE,
     ProxyManager,
     REPLICATED_MAP_SERVICE,
     VECTOR_SERVICE,
@@ -34,6 +34,7 @@
 from hazelcast.internal.asyncio_proxy.executor import Executor
 from hazelcast.internal.asyncio_proxy.list import List
 from hazelcast.internal.asyncio_proxy.map import Map
+from hazelcast.internal.asyncio_proxy.multi_map import MultiMap
 from hazelcast.internal.asyncio_proxy.replicated_map import ReplicatedMap
 from hazelcast.internal.asyncio_reactor import AsyncioReactor
 from hazelcast.serialization import SerializationServiceV1
@@ -287,6 +288,17 @@ async def get_map(self, name: str) -> Map[KeyType, ValueType]:
         """
         return await self._proxy_manager.get_or_create(MAP_SERVICE, name)
 
+    async def get_multi_map(self, name: str) -> MultiMap[KeyType, ValueType]:
+        """Returns the distributed MultiMap instance with the specified name.
+
+        Args:
+            name: Name of the distributed MultiMap.
+
+        Returns:
+            Distributed MultiMap instance with the specified name.
+        """
+        return await self._proxy_manager.get_or_create(MULTI_MAP_SERVICE, name)
+
     async def get_replicated_map(self, name: str) -> ReplicatedMap[KeyType, ValueType]:
         """Returns the distributed ReplicatedMap instance with the specified
         name.

hazelcast/internal/asyncio_proxy/manager.py

@@ -3,6 +3,7 @@
 
 from hazelcast.internal.asyncio_proxy.executor import create_executor_proxy
 from hazelcast.internal.asyncio_proxy.list import create_list_proxy
+from hazelcast.internal.asyncio_proxy.multi_map import create_multi_map_proxy
 from hazelcast.internal.asyncio_proxy.vector_collection import (
     create_vector_collection_proxy,
 )
@@ -16,6 +17,7 @@
 EXECUTOR_SERVICE = "hz:impl:executorService"
 LIST_SERVICE = "hz:impl:listService"
 MAP_SERVICE = "hz:impl:mapService"
+MULTI_MAP_SERVICE = "hz:impl:multiMapService"
 REPLICATED_MAP_SERVICE = "hz:impl:replicatedMapService"
 VECTOR_SERVICE = "hz:service:vector"
 
@@ -26,6 +28,7 @@
     EXECUTOR_SERVICE: create_executor_proxy,
     LIST_SERVICE: create_list_proxy,
     MAP_SERVICE: create_map_proxy,
+    MULTI_MAP_SERVICE: create_multi_map_proxy,
     REPLICATED_MAP_SERVICE: create_replicated_map_proxy,
     VECTOR_SERVICE: create_vector_collection_proxy,
 }