Python: fix: apply collection-name prefix to keys in RedisJsonCollection._inner_delete

python/semantic_kernel/connectors/redis.py

@@ -706,7 +706,7 @@ def _add_key(self, key: TKey, record: dict[str, Any]) -> dict[str, Any]:
 
     @override
     async def _inner_delete(self, keys: Sequence[str], **kwargs: Any) -> None:
-        await asyncio.gather(*[self.redis_database.json().delete(key, **kwargs) for key in keys])
+        await asyncio.gather(*[self.redis_database.json().delete(self._get_redis_key(key), **kwargs) for key in keys])
 
     @override
     def _serialize_dicts_to_store_models(

python/tests/unit/connectors/memory/test_redis_store.py

@@ -276,6 +276,17 @@ async def test_delete(collection_hash, collection_json, type_):
     await collection._inner_delete(["id1"])
 
 
+@mark.parametrize("type_", ["hash", "json"])
+async def test_delete_with_prefix(request, type_):
+    collection = request.getfixturevalue(f"collection_with_prefix_{type_}")
+    mock_delete = request.getfixturevalue(f"mock_delete_{type_}")
+
+    await collection._inner_delete(["id1"])
+
+    # Verify the collection-name prefix was applied to the key
+    mock_delete.assert_called_once_with("test:id1")
+
+
 async def test_collection_exists(collection_hash, mock_collection_exists):
     await collection_hash.collection_exists()