Add todos

artie-labs · Mar 29, 2024 · be724b1 · be724b1
1 parent 634c0df
commit be724b1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -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)
 		}