Skip to content

include_history for object store watch have no effect #638

@kfollesdal

Description

@kfollesdal

Observed behavior

Object store watch function have parameter include_history. If False delivery policy is set to LAST_PER_SUBJECT:

if not include_history:

If set to True then deliver_policy = None and then default to ALL:

# NOTE: deliver_policy is defaulting to ALL so check is different for this one.

But messages in underlying meta jetstream for object store is published with Nats-Rollup: sub. So we only have one message for each subject. So with this LAST_PER_SUBJECT and ALL will give same result at consumer start up. If I understand it correct?

Expected behavior

Expect include_history= False to give delivery policy NEW, only receive new changes from start up.

Server and client version

nats.py: 2.9.0

Host environment

No response

Steps to reproduce

No response

Metadata

Metadata

Assignees

Labels

acceptedThe defect or proposal as been accepteddefectSuspected defect such as a bug or regression

Type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions