Add TODO

gregfurman · gregfurman · commit b9efaef56361 · 2025-03-25T19:52:27.000+02:00
diff --git a/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/stream_poller.py b/localstack-core/localstack/services/lambda_/event_source_mapping/pollers/stream_poller.py
@@ -202,6 +202,7 @@ def poll_events_from_shard(self, shard_id: str, shard_iterator: str):
         for batch in batched(collected_records, self.stream_parameters.get("BatchSize")):
             # This could potentially lead to data loss if forward_events_to_target raises an exception after a flush
             # which would otherwise be solved with checkpointing.
+            # TODO: Implement checkpointing, leasing, etc. from https://docs.aws.amazon.com/streams/latest/dev/kcl-concepts.html
             self.forward_events_to_target(shard_id, next_shard_iterator, batch)
 
     def forward_events_to_target(self, shard_id, next_shard_iterator, records):
