Simplify entity streaming metrics code

There’s no need to do batched metric increments until this becomes a performance bottleneck.
alephdata · Nov 23, 2023 · 7aabc4f · 7aabc4f
1 parent 2e7f61d
commit 7aabc4f
Showing 1 changed file with 1 addition and 10 deletions.
diff --git a/aleph/views/stream_api.py b/aleph/views/stream_api.py
@@ -68,17 +68,8 @@ def entities(collection_id=None):
     STREAMS.inc()
 
     def generator(entities):
-        count = 0
-
         for entity in entities:
-            count += 1
-
-            if count == 1000:
-                STREAMED_ENTITIES.inc(count)
-                count = 0
-
+            STREAMED_ENTITIES.inc()
             yield entity
 
-        STREAMED_ENTITIES.inc(count)
-
     return stream_ijson(generator(entities))