DR

Author: bartelink

src/Propulsion.DynamoStore.Indexer/Handler.fs

@@ -2,10 +2,9 @@ module Propulsion.DynamoStore.Indexer.Handler
 
 open Amazon.DynamoDBStreams
 open Amazon.DynamoDBv2
-open Amazon.Lambda.DynamoDBEvents
 open Propulsion.DynamoStore
 
-let private parse (log: Serilog.ILogger) (dynamoEvent: DynamoDBEvent): AppendsEpoch.Events.StreamSpan[] =
+let private parse (log: Serilog.ILogger) (dynamoEvent: Amazon.Lambda.DynamoDBEvents.DynamoDBEvent): AppendsEpoch.Events.StreamSpan[] =
     let spans, summary = ResizeArray(), System.Text.StringBuilder()
     let mutable indexStream, systemStreams, noEvents = 0, 0, 0
     try for record in dynamoEvent.Records do

src/Propulsion.DynamoStore.Notifier/Handler.fs

@@ -1,7 +1,6 @@
 module Propulsion.DynamoStore.Notifier.Handler
 
 open Amazon.DynamoDBStreams
-open Amazon.Lambda.DynamoDBEvents
 open Amazon.SimpleNotificationService
 open Amazon.SimpleNotificationService.Model
 open Propulsion.DynamoStore
@@ -10,7 +9,7 @@ open System.Collections.Generic
 open System.Net
 open System.Threading
 
-let private parse (log: Serilog.ILogger) (dynamoEvent: DynamoDBEvent): KeyValuePair<AppendsPartitionId, Propulsion.Feed.Position>[]  =
+let private parse (log: Serilog.ILogger) (dynamoEvent: Amazon.Lambda.DynamoDBEvents.DynamoDBEvent): KeyValuePair<AppendsPartitionId, Propulsion.Feed.Position>[]  =
     let tails = Dictionary()
     let updateTails partitionId checkpoint =
         match tails.TryGetValue partitionId with