fix: ♻️ Corrected the incorrect references for StartingPosition prope…

…rty in DynamoDB & kinesisStreams
distinction-dev · Sep 11, 2023 · b7cd1e1 · b7cd1e1
1 parent 58a836a
commit b7cd1e1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/docs/parameters/DynamoDBSourceParameters.md b/docs/parameters/DynamoDBSourceParameters.md
@@ -119,7 +119,7 @@ The number of batches to process concurrently from each shard. The default value
 [schema.ts:42](https://github.com/distinction-dev/serverless-pipes/blob/adc1ce1b20b719d2e58f62a01c813e4ef9c57a5c/src/schema.ts#L42)
 
 
-### startingPosition (optional)
+### startingPosition
 
 • **startingPosition**: `string`
 

diff --git a/src/compiler.ts b/src/compiler.ts
@@ -40,8 +40,7 @@ export function compileBasedOnSourceType(
     case "dynamodb": {
       const params: AWSPipesPipePipeSourceParametersDefinition = {
         DynamoDBStreamParameters: {
-          StartingPosition:
-            config.source[sourceName].parallelizationFactor || "",
+          StartingPosition: config.source[sourceName].startingPosition || "",
           BatchSize: config.source[sourceName]?.batchsize || 10,
           DeadLetterConfig: {
             Arn: config.source[sourceName]?.deadLetterArn || "",
@@ -63,8 +62,7 @@ export function compileBasedOnSourceType(
     case "kinesisStream": {
       const params: AWSPipesPipePipeSourceParametersDefinition = {
         KinesisStreamParameters: {
-          StartingPosition:
-            config.source[sourceName].parallelizationFactor || "",
+          StartingPosition: config.source[sourceName].startingPosition || "",
           BatchSize: config.source[sourceName]?.batchsize || 10,
           DeadLetterConfig: {
             Arn: config.source[sourceName]?.deadLetterArn || "",