@@ -79,14 +79,14 @@ def test_GzippedWhisperReader_get_intervals(self):
79
79
ts = int (time .time ())
80
80
intervals = reader .get_intervals ()
81
81
for interval in intervals :
82
- self .assertEqual (int (interval .start ), ts - 60 )
83
- self .assertEqual (int (interval .end ), ts )
82
+ self .assertEqual (int (interval .start ), ts - 60 )
83
+ self .assertIn (int (interval .end ), [ ts , ts - 1 ] )
84
84
85
85
# read it again to validate cache works
86
86
intervals = reader .get_intervals ()
87
87
for interval in intervals :
88
- self .assertEqual (int (interval .start ),ts - 60 )
89
- self .assertEqual (int (interval .end ), ts )
88
+ self .assertEqual (int (interval .start ),ts - 60 )
89
+ self .assertIn (int (interval .end ), [ ts , ts - 1 ] )
90
90
91
91
# Confirm fetch works.
92
92
def test_GzippedWhisperReader_fetch (self ):
@@ -120,14 +120,14 @@ def test_WhisperReader_get_intervals(self):
120
120
ts = int (time .time ())
121
121
intervals = reader .get_intervals ()
122
122
for interval in intervals :
123
- self .assertEqual (int (interval .start ),ts - 60 )
124
- self .assertEqual (int (interval .end ), ts )
123
+ self .assertEqual (int (interval .start ),ts - 60 )
124
+ self .assertIn (int (interval .end ), [ ts , ts - 1 ] )
125
125
126
126
# read it again to validate cache works
127
127
intervals = reader .get_intervals ()
128
128
for interval in intervals :
129
- self .assertEqual (int (interval .start ),ts - 60 )
130
- self .assertEqual (int (interval .end ), ts )
129
+ self .assertEqual (int (interval .start ),ts - 60 )
130
+ self .assertIn (int (interval .end ), [ ts , ts - 1 ] )
131
131
132
132
# Confirm get_raw_step works
133
133
def test_WhisperReader_get_raw_step (self ):
0 commit comments