Skip to content

Commit 17b5975

Browse files
committed
Moved check to recorder
1 parent 5e7d903 commit 17b5975

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

splitio/recorder/recorder.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -129,6 +129,8 @@ def record_treatment_stats(self, impressions, latency, operation):
129129
if self._data_sampling < rnumber:
130130
return
131131
impressions = self._impressions_manager.process_impressions(impressions)
132+
if impressions == []:
133+
return
132134
# pipe = self._make_pipe()
133135
# self._impression_storage.add_impressions_to_pipe(impressions, pipe)
134136
# self._telemetry_storage.add_latency_to_pipe(operation, latency, pipe)

splitio/storage/redis.py

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -431,8 +431,6 @@ def put(self, impressions):
431431
:return: Whether the impression has been added or not.
432432
:rtype: bool
433433
"""
434-
if impressions == []:
435-
return False
436434
bulk_impressions = self._wrap_impressions(impressions)
437435
try:
438436
inserted = self._redis.rpush(self.IMPRESSIONS_QUEUE_KEY, *bulk_impressions)

0 commit comments

Comments
 (0)