diff --git a/sources/dynamodb/shard.go b/sources/dynamodb/shard.go
index 89291586..2d421c55 100644
--- a/sources/dynamodb/shard.go
+++ b/sources/dynamodb/shard.go
@@ -97,6 +97,7 @@ func (s *StreamStore) processShard(ctx context.Context, shard *dynamodbstreams.S
 			messages = append(messages, msg.RawMessage())
 		}
 
+		// TODO: Create an actual iterator over the shards that is passed to the writer.
 		if _, err = _writer.Write(ctx, lib.NewSingleBatchIterator(messages)); err != nil {
 			logger.Panic("Failed to publish messages, exiting...", slog.Any("err", err))
 		}
diff --git a/sources/dynamodb/snapshot.go b/sources/dynamodb/snapshot.go
index 9895dbc4..f2cb701c 100644
--- a/sources/dynamodb/snapshot.go
+++ b/sources/dynamodb/snapshot.go
@@ -93,6 +93,7 @@ func (s *SnapshotStore) streamAndPublish(ctx context.Context, _writer writer.Wri
 			messages = append(messages, dynamoMsg.RawMessage())
 		}
 
+		// TODO: Create an actual iterator over the files that is passed to the writer.
 		if _, err := _writer.Write(ctx, lib.NewSingleBatchIterator(messages)); err != nil {
 			return fmt.Errorf("failed to publish messages: %w", err)
 		}