Compile.

artie-labs · Jul 14, 2024 · d348df7 · d348df7
1 parent 94a963d
commit d348df7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sources/dynamodb/dynamodb.go b/sources/dynamodb/dynamodb.go
@@ -44,7 +44,7 @@ func Load(cfg config.DynamoDB) (sources.Source, bool, error) {
 			cfg:       &cfg,
 			storage:   offsets.NewStorage(cfg.OffsetFile, nil, nil),
 			streams:   dynamodbstreams.NewFromConfig(_awsCfg),
-			shardChan: make(chan *types.Shard),
+			shardChan: make(chan types.Shard),
 		}, true, nil
 	}
 }