We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6521df6 commit fdeceb0Copy full SHA for fdeceb0
1 file changed
aw_client/client.py
@@ -229,7 +229,7 @@ def heartbeat(
229
# If last_heartbeat becomes longer than commit_interval
230
# then commit, else cache merged.
231
diff = (last_heartbeat.duration).total_seconds()
232
- if diff > commit_interval:
+ if diff >= commit_interval:
233
data = merge.to_json_dict()
234
self.request_queue.add_request(endpoint, data)
235
self.last_heartbeat[bucket_id] = event
0 commit comments