Merge pull request #134 from Amsterdam/feature/increase-batch-size

Increase default_batch_size to 10000
Amsterdam · Mar 18, 2021 · 60a4819 · 60a4819
2 parents 8b56cae + a2b09c5
commit 60a4819
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/telcameras_v3/ingress_parser.py b/src/telcameras_v3/ingress_parser.py
@@ -24,6 +24,9 @@ class TelcameraParser(BaseConsumer):
     """
     set_consume_started_at = True
 
+    def get_default_batch_size(self):
+        return 10000
+
     def consume_raw_data(self, raw_data):
         observation = json.loads(raw_data)
         observation['message_id'] = observation.pop('id')