Skip to content
This repository was archived by the owner on Jan 24, 2023. It is now read-only.

Commit d060b07

Browse files
author
Ariel Shtul
authored
Remove reset flag from inctby (#23)
* fix test * avoid same timestamp * fix tests * . * remove failing test that are check on RTS itself * Remove reset
1 parent 5bde293 commit d060b07

File tree

2 files changed

+0
-8
lines changed

2 files changed

+0
-8
lines changed

redistimeseries/client.py

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -111,11 +111,6 @@ def appendRetention(params, retention):
111111
if retention is not None:
112112
params.extend(['RETENTION', retention])
113113

114-
@staticmethod
115-
def appendTimeBucket(params, time_bucket):
116-
if time_bucket is not None:
117-
params.extend(['RESET', time_bucket])
118-
119114
@staticmethod
120115
def appendLabels(params, labels):
121116
if labels:
@@ -188,7 +183,6 @@ def incrby(self, key, value, time_bucket=None,
188183
applied.
189184
"""
190185
params = [key, value]
191-
self.appendTimeBucket(params, time_bucket)
192186
self.appendRetention(params, retention_msecs)
193187
self.appendLabels(params, labels)
194188

@@ -203,7 +197,6 @@ def decrby(self, key, value, time_bucket=None,
203197
applied.
204198
"""
205199
params = [key, value]
206-
self.appendTimeBucket(params, time_bucket)
207200
self.appendRetention(params, retention_msecs)
208201
self.appendLabels(params, labels)
209202

test_commands.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -58,7 +58,6 @@ def testMAdd(self):
5858
def testIncrbyDecrby(self):
5959
'''Test TS.INCRBY and TS.DECRBY calls'''
6060

61-
#test without counter reset
6261
for _ in range(100):
6362
self.assertTrue(rts.incrby(1,1))
6463
sleep(0.001)

0 commit comments

Comments
 (0)