File tree Expand file tree Collapse file tree 4 files changed +3
-4
lines changed Expand file tree Collapse file tree 4 files changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -88,7 +88,7 @@ module Cosmos =
88
88
let containerId = p.GetResult( Container, fun () -> c.CosmosContainer)
89
89
let leasesContainerName = p.GetResult( LeaseContainer, fun () -> containerId + p.GetResult( Suffix, " -aux" ))
90
90
let checkpointInterval = TimeSpan.hours 1.
91
- member val MaybeLogLagInterval = p.TryGetResult LagFreqM |> Option.map TimeSpan.minutes
91
+ member val MaybeLogLagInterval = p.TryPostProcessResult ( LagFreqM, TimeSpan.minutes)
92
92
member _.CreateLeasesContainer () = connector.CreateLeasesContainer( databaseId, leasesContainerName)
93
93
member _.ConnectFeed () = connector.ConnectFeed( databaseId, containerId, leasesContainerName)
94
94
member x.CreateCheckpointStore ( group , cache , storeLog ) = async {
Original file line number Diff line number Diff line change @@ -26,7 +26,6 @@ module Sinks =
26
26
if verbose then t else t.Replace( " {Properties}" , " " )
27
27
configuration.WriteTo.Console( theme = Sinks.SystemConsole.Themes.AnsiConsoleTheme.Code, outputTemplate = outputTemplate)
28
28
29
- [<System.Runtime.CompilerServices.Extension>]
30
29
type Logging () =
31
30
32
31
[<System.Runtime.CompilerServices.Extension>]
Original file line number Diff line number Diff line change @@ -203,7 +203,7 @@ module Indexer =
203
203
type Arguments ( c , p : ParseResults < IndexParameters >) =
204
204
member val GapsLimit = p.GetResult( IndexParameters.GapsLimit, 10 )
205
205
member val ImportJsonFiles = p.GetResults IndexParameters.DynamoDbJson
206
- member val TrancheId = p.TryGetResult IndexParameters.IndexPartitionId |> Option.map ( string >> AppendsPartitionId.parse)
206
+ member val TrancheId = p.TryPostProcessResult ( IndexParameters.IndexPartitionId, string >> AppendsPartitionId.parse)
207
207
// Larger optimizes for not needing to use TransactWriteItems as frequently
208
208
// Smaller will trigger more items and reduce read costs for Sources reading from the tail
209
209
member val MinItemSize = p.GetResult( IndexParameters.MinSizeK, 48 )
Original file line number Diff line number Diff line change 28
28
<ItemGroup >
29
29
<PackageReference Include =" MinVer" Version =" 4.2.0" PrivateAssets =" All" />
30
30
31
- <PackageReference Include =" Argu" Version =" 6.1.3 " />
31
+ <PackageReference Include =" Argu" Version =" 6.1.4 " />
32
32
<!-- Required or there'll be an exception at runtime re missing support DLLs when using RBAC -->
33
33
<PackageReference Include =" AWSSDK.SecurityToken" Version =" 3.7.1.177" />
34
34
<!-- Required for AWS SSO resolution -->
You can’t perform that action at this time.
0 commit comments