Skip to content

Commit

Permalink
Merge branch 'release/v2.2.0'
Browse files Browse the repository at this point in the history
  • Loading branch information
wallyqs committed Oct 1, 2022
2 parents 0fcfaf2 + ba35491 commit e8bb941
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion nats/js/manager.py
Original file line number Diff line number Diff line change
Expand Up @@ -326,7 +326,7 @@ def _lift_msg_to_raw_msg(self, msg) -> api.RawStreamMsg:

async def delete_msg(self, stream_name: str, seq: int) -> bool:
"""
get_msg retrieves a message from a stream based on the sequence ID.
delete_msg retrieves a message from a stream based on the sequence ID.
"""
req_subject = f"{self._prefix}.STREAM.MSG.DELETE.{stream_name}"
req = {'seq': seq}
Expand Down
2 changes: 1 addition & 1 deletion tests/test_js.py
Original file line number Diff line number Diff line change
Expand Up @@ -1874,7 +1874,7 @@ async def error_handler(e):
assert b'world' == entry.value
assert 1 == entry.revision

# Now get the the same KV via lookup.
# Now get the same KV via lookup.
kv = await js.key_value("TEST")
entry = await kv.get("hello")
assert "hello" == entry.key
Expand Down

0 comments on commit e8bb941

Please sign in to comment.