WIP

tests/harness.py

@@ -466,7 +466,7 @@ async def delete_multi(
             # TODO: Test below transaction codes
             actions = []
             for k in keys:
-                actions.append(TxnOp.delete(k))
+                actions.append(TxnOp.delete(self._mangle_key(f"{_slash(scope_prefix)}{k}")))
             txn = EtcdTransactionAction()
             communicator.txn(txn.and_then(actions).or_else([]))
 

tests/test.py

@@ -179,26 +179,26 @@ async def test_scope_dict(etcd: AsyncEtcd) -> None:
     assert len(vp) == 0
 
 
-# @pytest.mark.asyncio
-# async def test_multi(etcd: AsyncEtcd) -> None:
-#     etcd = await etcd
-
-#     v = await etcd.get("foo")
-#     assert v is None
-#     v = await etcd.get("bar")
-#     assert v is None
-
-#     await etcd.put_dict({"foo": "x", "bar": "y"})
-#     v = await etcd.get("foo")
-#     assert v == "x"
-#     v = await etcd.get("bar")
-#     assert v == "y"
-
-#     await etcd.delete_multi(["foo", "bar"])
-#     v = await etcd.get("foo")
-#     assert v is None
-#     v = await etcd.get("bar")
-#     assert v is None
+@pytest.mark.asyncio
+async def test_multi(etcd: AsyncEtcd) -> None:
+    etcd = await etcd
+
+    v = await etcd.get("foo")
+    assert v is None
+    v = await etcd.get("bar")
+    assert v is None
+
+    await etcd.put_dict({"foo": "x", "bar": "y"})
+    v = await etcd.get("foo")
+    assert v == "x"
+    v = await etcd.get("bar")
+    assert v == "y"
+
+    await etcd.delete_multi(["foo", "bar"])
+    v = await etcd.get("foo")
+    assert v is None
+    v = await etcd.get("bar")
+    assert v is None
 
 
 @pytest.mark.asyncio