We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ad0f65a commit 443260cCopy full SHA for 443260c
1 file changed
tests/test_stream_ops.py
@@ -944,11 +944,11 @@ async def test_encrypted_stream_requires_key(
944
await stream.append(
945
AppendInput(records=[Record(body=b"hello")])
946
)
947
- assert append_exc.value.code == "invalid"
+ assert append_exc.value.code == "bad_header"
948
assert cipher.value in str(append_exc.value)
949
with pytest.raises(S2ServerError) as read_exc:
950
await stream.read(start=SeqNum(0))
951
- assert read_exc.value.code == "invalid"
+ assert read_exc.value.code == "bad_header"
952
assert cipher.value in str(read_exc.value)
953
finally:
954
await basin.delete_stream(stream_name)
0 commit comments