(self, r)
| 6909 | |
| 6910 | @skip_if_server_version_lt("8.7.2") |
| 6911 | def test_xnack_retrycount(self, r): |
| 6912 | stream = "stream" |
| 6913 | group = "group" |
| 6914 | consumer = "consumer" |
| 6915 | m1 = r.xadd(stream, {"foo": "bar"}) |
| 6916 | r.xgroup_create(stream, group, 0) |
| 6917 | r.xreadgroup(group, consumer, streams={stream: ">"}) |
| 6918 | # Explicit retrycount overrides mode's counter adjustment |
| 6919 | result = r.xnack(stream, group, "FAIL", m1, retrycount=5) |
| 6920 | assert result == 1 |
| 6921 | |
| 6922 | @skip_if_server_version_lt("8.7.2") |
| 6923 | def test_xnack_force(self, r): |
nothing calls this directly
no test coverage detected