nats-io/nats.py v2.10.0

Release v2.10.0

on GitHub

Added

• Added KeysWithFilters method for key filtering in KV bucket (by @somratdutta in #602)

    # Retrieve keys with filters
    filtered_keys = await kv.keys(filters=['hello', 'greet'])
    print(f'Filtered Keys: {filtered_keys}')

• Add discard_new_per_subject to StreamConfig (by @caspervonb in #609)

config = nats.js.api.StreamConfig(
          name=stream_name,
          discard=nats.js.api.DiscardPolicy.NEW,
          discard_new_per_subject=True,
          max_msgs_per_subject=100
      )

await js.add_stream(config)

• Added support for passing pathlib.Path derived types to user_credentials (by @johnweldon in #623)

• Add an is_acked property to nats.aio.msg.Msg (by @charles-dyfis-net in #672)

Fixed

• Fixed typing of JetStreamContext.publish by @rijenkii in #605
• Fixed supporting REQUEST_TIMEOUT status code for a batch fetch with no_wait=True (by @diorcety in #618)
• Fixed deliver_subject in implicit subscription creation (by @m3nowak in #615)
• Fixed issue where flusher task stops running (by @debbyglance in #636)
• Fixed service start times to be utc (by @apollo13 in #640)
• Fixed discovered server callback not being awaited (by @caspervonb in #660)

Improved

• Validate stream name in add_stream method (by @ff137 in #607)
• Timezone-aware datetime (by @diorcety in #648)
• Improved server version semver handling (by @robinbowes in #679)