Target Equinox 4rc7, Propulsion 3rc1 (#128)

jet · Dec 23, 2022 · 4ab931c · 4ab931c
1 parent ce7aea1
commit 4ab931c
Show file tree

Hide file tree

Showing 49 changed files with 173 additions and 167 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -14,7 +14,7 @@ The `Unreleased` section name is replaced by the expected version of next releas
 
 ### Changed
 
-- Target `Equinox` v `4.0.0-rc.6`, `Propulsion` v `3.0.0-beta.7`, `FsCodec` v `3.0.0-rc.9`, `net6.0` [#126](https:/jet/dotnet-templates/pull/126)
+- Target `Equinox` v `4.0.0-rc.7`, `Propulsion` v `3.0.0-rc.1`, `FsCodec` v `3.0.0-rc.9`, `net6.0` [#126](https:/jet/dotnet-templates/pull/126) [#127](https:/jet/dotnet-templates/pull/127)
 
 ### Removed 
 

diff --git a/equinox-patterns/Domain/Domain.fsproj b/equinox-patterns/Domain/Domain.fsproj
@@ -16,8 +16,8 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  </ItemGroup>
 

diff --git a/equinox-shipping/Domain.Tests/Domain.Tests.fsproj b/equinox-shipping/Domain.Tests/Domain.Tests.fsproj
@@ -20,7 +20,7 @@
  <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.2.0" />
 
  <PackageReference Include="FsCheck.Xunit" Version="3.0.0-beta2" />
- <PackageReference Include="Propulsion.MemoryStore" Version="3.0.0-beta.7" />
+ <PackageReference Include="Propulsion.MemoryStore" Version="3.0.0-rc.1" />
  <PackageReference Include="xunit" Version="2.4.2" />
  <PackageReference Include="xunit.runner.visualstudio" Version="2.4.5" />
  </ItemGroup>

diff --git a/equinox-shipping/Domain/Domain.fsproj b/equinox-shipping/Domain/Domain.fsproj
@@ -20,10 +20,10 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  </ItemGroup>
 

diff --git a/equinox-shipping/Watchdog.Integration/ReactorFixture.fs b/equinox-shipping/Watchdog.Integration/ReactorFixture.fs
@@ -40,7 +40,7 @@ type FixtureBase(messageSink, store, dumpStats, createSourceConfig) =
  stats.StatsInterval.SleepUntilTriggerCleared()
  member _.Await(propagationDelay) =
  match awaitReactions with
- | Some f -> f propagationDelay
+ | Some f -> f propagationDelay |> Async.ofTask
  | None -> async { () }
 
  interface IDisposable with

diff --git a/equinox-shipping/Watchdog.Lambda.Cdk/Watchdog.Lambda.Cdk.fsproj b/equinox-shipping/Watchdog.Lambda.Cdk/Watchdog.Lambda.Cdk.fsproj
@@ -20,7 +20,7 @@
  <!-- jsii Roslyn analyzers (un-comment to obtain compile-time checks for missing required props-->
  <!-- <PackageReference Include="Amazon.Jsii.Analyzers" Version="*" PrivateAssets="all" />-->
 
- <PackageReference Include="Propulsion.DynamoStore.Constructs" Version="3.0.0-beta.7" />
+ <PackageReference Include="Propulsion.DynamoStore.Constructs" Version="3.0.0-rc.1" />
  </ItemGroup>
 
 </Project>
diff --git a/equinox-shipping/Watchdog.Lambda/Watchdog.Lambda.fsproj b/equinox-shipping/Watchdog.Lambda/Watchdog.Lambda.fsproj
@@ -16,7 +16,7 @@
  <ItemGroup>
  <PackageReference Include="Amazon.Lambda.Core" Version="2.1.0" />
  <PackageReference Include="Amazon.Lambda.Serialization.SystemTextJson" Version="2.3.0" />
- <PackageReference Include="Propulsion.DynamoStore.Lambda" Version="3.0.0-beta.7" />
+ <PackageReference Include="Propulsion.DynamoStore.Lambda" Version="3.0.0-rc.1" />
  </ItemGroup>
  <ItemGroup>
  <ProjectReference Include="..\Watchdog\Watchdog.fsproj" />

diff --git a/equinox-shipping/Watchdog/Handler.fs b/equinox-shipping/Watchdog/Handler.fs
@@ -12,19 +12,27 @@ type Stats(log, statsInterval, stateInterval, verboseStore, ?logExternalStats) =
 
  let mutable completed, deferred, failed, succeeded = 0, 0, 0, 0
 
+ override _.HandleOk res = res |> function
+ | Outcome.Completed -> completed <- completed + 1
+ | Outcome.Deferred -> deferred <- deferred + 1
+ | Outcome.Resolved successfully -> if successfully then succeeded <- succeeded + 1 else failed <- failed + 1
  override _.DumpStats() =
  base.DumpStats()
  if completed <> 0 || deferred <> 0 || failed <> 0 || succeeded <> 0 then
  log.Information(" Completed {completed} Deferred {deferred} Failed {failed} Succeeded {succeeded}", completed, deferred, failed, succeeded)
  completed <- 0; deferred <- 0; failed <- 0; succeeded <- 0
  match logExternalStats with None -> () | Some f -> f Serilog.Log.Logger
 
- override _.HandleOk res = res |> function
- | Outcome.Completed -> completed <- completed + 1
- | Outcome.Deferred -> deferred <- deferred + 1
- | Outcome.Resolved successfully -> if successfully then succeeded <- succeeded + 1 else failed <- failed + 1
+ override _.Classify(exn) =
+ match exn with
+ | Equinox.DynamoStore.Exceptions.ProvisionedThroughputExceeded -> Propulsion.Streams.OutcomeKind.RateLimited
+ | :? Microsoft.Azure.Cosmos.CosmosException as e
+ when (e.StatusCode = System.Net.HttpStatusCode.TooManyRequests
+ || e.StatusCode = System.Net.HttpStatusCode.ServiceUnavailable)
+ && not verboseStore -> Propulsion.Streams.OutcomeKind.RateLimited
+ | x -> base.Classify x
  override _.HandleExn(log, exn) =
- Exception.dump verboseStore log exn
+ log.Information(exn, "Unhandled")
 
 open Shipping.Domain
 
@@ -35,7 +43,7 @@ let private isReactionStream = function
 let handle
  (processingTimeout : TimeSpan)
  (driveTransaction : Shipping.Domain.TransactionId -> Async<bool>)
- struct (stream, span) = async {
+ stream span ct = Propulsion.Internal.Async.startImmediateAsTask ct <| async {
  let processingStuckCutoff = let now = DateTimeOffset.UtcNow in now.Add(-processingTimeout)
  match stream, span with
  | TransactionWatchdog.Finalization.MatchStatus (transId, state) ->
@@ -55,8 +63,8 @@ let handle
 type Config private () =
 
  static member private StartSink(log : Serilog.ILogger, stats : Stats,
- handle : struct (FsCodec.StreamName * Propulsion.Streams.Default.StreamSpan)
- -> Async<struct (Propulsion.Streams.SpanResult * Outcome)>,
+ handle : System.Func<FsCodec.StreamName, Propulsion.Streams.Default.StreamSpan, _,
+ System.Threading.Tasks.Task<struct (Propulsion.Streams.SpanResult * Outcome)>>,
  maxReadAhead : int, maxConcurrentStreams : int, ?wakeForResults, ?idleDelay, ?purgeInterval) =
  Propulsion.Streams.Default.Config.Start(log, maxReadAhead, maxConcurrentStreams, handle, stats, stats.StatsInterval.Period,
  ?wakeForResults = wakeForResults, ?idleDelay = idleDelay, ?purgeInterval = purgeInterval)

diff --git a/equinox-shipping/Watchdog/Infrastructure.fs b/equinox-shipping/Watchdog/Infrastructure.fs
@@ -8,21 +8,6 @@ module EnvVar =
 
  let tryGet varName : string option = Environment.GetEnvironmentVariable varName |> Option.ofObj
 
-module Exception =
-
- let dump verboseStore (log : ILogger) (exn : exn) =
- match exn with // TODO provide override option?
- | :? Microsoft.Azure.Cosmos.CosmosException as e
- when (e.StatusCode = System.Net.HttpStatusCode.TooManyRequests
- || e.StatusCode = System.Net.HttpStatusCode.ServiceUnavailable)
- && not verboseStore -> ()
-
- | Equinox.DynamoStore.Exceptions.ProvisionedThroughputExceeded
- | :? TimeoutException when not verboseStore -> ()
-
- | _ ->
- log.Information(exn, "Unhandled")
-
 type Equinox.CosmosStore.CosmosStoreConnector with
 
  member private x.LogConfiguration(connectionName, databaseId, containerId) =

diff --git a/equinox-shipping/Watchdog/SourceConfig.fs b/equinox-shipping/Watchdog/SourceConfig.fs
@@ -1,6 +1,7 @@
 namespace Shipping.Infrastructure
 
 open System
+open System.Threading.Tasks
 
 [<RequireQualifiedAccess; NoEquality; NoComparison>]
 type SourceConfig =
@@ -33,13 +34,13 @@ module SourceConfig =
  module Memory =
  open Propulsion.MemoryStore
  let start log (sink : Propulsion.Streams.Default.Sink) categoryFilter
- (store : Equinox.MemoryStore.VolatileStore<_>) : Propulsion.Pipeline * (TimeSpan -> Async<unit>) option =
+ (store : Equinox.MemoryStore.VolatileStore<_>) : Propulsion.Pipeline * (TimeSpan -> Task<unit>) option =
  let source = MemoryStoreSource(log, store, categoryFilter, sink)
  source.Start(), Some (fun _propagationDelay -> source.Monitor.AwaitCompletion(ignoreSubsequent = false))
  module Cosmos =
  open Propulsion.CosmosStore
  let start log (sink : Propulsion.Streams.Default.Sink) categoryFilter
- (monitoredContainer, leasesContainer, checkpointConfig, tailSleepInterval) : Propulsion.Pipeline * (TimeSpan -> Async<unit>) option =
+ (monitoredContainer, leasesContainer, checkpointConfig, tailSleepInterval) : Propulsion.Pipeline * (TimeSpan -> Task<unit>) option =
  let parseFeedDoc = EquinoxSystemTextJsonParser.enumStreamEvents categoryFilter
  let observer = CosmosStoreSource.CreateObserver(log, sink.StartIngester, Seq.collect parseFeedDoc)
  let source =
@@ -69,14 +70,14 @@ module SourceConfig =
  checkpoints, sink, loadMode,
  startFromTail = startFromTail, storeLog = storeLog, ?trancheIds = trancheIds)
  let start (log, storeLog) sink categoryFilter (indexStore, checkpoints, loadModeConfig, startFromTail, tailSleepInterval, batchSizeCutoff, statsInterval)
- : Propulsion.Pipeline * (TimeSpan -> Async<unit>) option =
+ : Propulsion.Pipeline * (TimeSpan -> Task<unit>) option =
  let source = create (log, storeLog) sink categoryFilter (indexStore, checkpoints, loadModeConfig, startFromTail, tailSleepInterval, batchSizeCutoff, statsInterval) None
  let source = source.Start()
  source, Some (fun propagationDelay -> source.Monitor.AwaitCompletion(propagationDelay, ignoreSubsequent = false))
  module Esdb =
  open Propulsion.EventStoreDb
  let start log (sink : Propulsion.Streams.Default.Sink) categoryFilter
- (client, checkpoints, hydrateBodies, startFromTail, batchSize, tailSleepInterval, statsInterval) : Propulsion.Pipeline * (TimeSpan -> Async<unit>) option =
+ (client, checkpoints, hydrateBodies, startFromTail, batchSize, tailSleepInterval, statsInterval) : Propulsion.Pipeline * (TimeSpan -> Task<unit>) option =
  let source =
  EventStoreSource(
  log, statsInterval,
@@ -85,7 +86,7 @@ module SourceConfig =
  let source = source.Start()
  source, Some (fun propagationDelay -> source.Monitor.AwaitCompletion(propagationDelay, ignoreSubsequent = false))
 
- let start (log, storeLog) sink categoryFilter : SourceConfig -> Propulsion.Pipeline * (TimeSpan -> Async<unit>) option = function
+ let start (log, storeLog) sink categoryFilter : SourceConfig -> Propulsion.Pipeline * (TimeSpan -> Task<unit>) option = function
  | SourceConfig.Memory volatileStore ->
  Memory.start log sink categoryFilter volatileStore
  | SourceConfig.Cosmos (monitored, leases, checkpointConfig, tailSleepInterval) ->

diff --git a/equinox-shipping/Watchdog/Watchdog.fsproj b/equinox-shipping/Watchdog/Watchdog.fsproj
@@ -18,10 +18,10 @@
 
  <ItemGroup>
  <PackageReference Include="Argu" Version="6.1.1" />
- <PackageReference Include="Propulsion.CosmosStore" Version="3.0.0-beta.7" />
- <PackageReference Include="Propulsion.DynamoStore" Version="3.0.0-beta.7" />
- <PackageReference Include="Propulsion.EventStoreDb" Version="3.0.0-beta.7" />
- <PackageReference Include="Propulsion.MemoryStore" Version="3.0.0-beta.7" />
+ <PackageReference Include="Propulsion.CosmosStore" Version="3.0.0-rc.1" />
+ <PackageReference Include="Propulsion.DynamoStore" Version="3.0.0-rc.1" />
+ <PackageReference Include="Propulsion.EventStoreDb" Version="3.0.0-rc.1" />
+ <PackageReference Include="Propulsion.MemoryStore" Version="3.0.0-rc.1" />
  <PackageReference Include="Serilog.Sinks.Console" Version="4.0.1" />
  </ItemGroup>
 

diff --git a/equinox-testbed/Testbed.fsproj b/equinox-testbed/Testbed.fsproj
@@ -17,10 +17,10 @@
 
  <ItemGroup>
  <PackageReference Include="Argu" Version="6.1.1" />
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.Tools.TestHarness" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.Tools.TestHarness" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  <PackageReference Include="Microsoft.Extensions.DependencyInjection" Version="5.0.2" />
  <PackageReference Include="Serilog.Sinks.Console" Version="4.0.1" />

diff --git a/equinox-web-csharp/Domain/Domain.csproj b/equinox-web-csharp/Domain/Domain.csproj
@@ -5,7 +5,7 @@
  </PropertyGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
  </ItemGroup>

diff --git a/equinox-web-csharp/Web/Web.csproj b/equinox-web-csharp/Web/Web.csproj
@@ -5,10 +5,10 @@
  </PropertyGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
  <PackageReference Include="prometheus-net.AspNetCore" Version="3.6.0" />
  <PackageReference Include="Serilog.AspNetCore" Version="3.2.0" />
  <PackageReference Include="Serilog.Sinks.Console" Version="4.0.1" />

diff --git a/equinox-web/Domain/Domain.fsproj b/equinox-web/Domain/Domain.fsproj
@@ -17,10 +17,10 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.DynamoStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.EventStoreDb" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  </ItemGroup>
 

diff --git a/equinox-web/Web/Startup.fs b/equinox-web/Web/Startup.fs
@@ -75,7 +75,7 @@ module Storage =
 
  let connect (region, table) (timeout, retries) =
  let c = DynamoStoreConnector(region, timeout, retries)
- DynamoStoreClient.Connect(c.CreateClient(), table) |> Async.RunSynchronously |> DynamoStoreContext.create
+ DynamoStoreClient.Establish(c.CreateClient(), table) |> Async.RunSynchronously |> DynamoStoreContext.create
 
 //#endif
  /// Creates and/or connects to a specific store as dictated by the specified config

diff --git a/equinox-web/Web/Web.fsproj b/equinox-web/Web/Web.fsproj
@@ -11,8 +11,8 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.DynamoStore.Prometheus" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.DynamoStore.Prometheus" Version="4.0.0-rc.7" />
  <PackageReference Include="prometheus-net.AspNetCore" Version="3.6.0" />
  <PackageReference Include="Serilog.AspNetCore" Version="3.2.0" />
  <PackageReference Include="Serilog.Sinks.Console" Version="4.0.1" />

diff --git a/feed-consumer/ApiClient.fs b/feed-consumer/ApiClient.fs
@@ -1,6 +1,7 @@
 module FeedConsumerTemplate.ApiClient
 
 open FSharp.UMX
+open Propulsion.Internal
 open System.Net.Http
 
 open FeedConsumerTemplate.Domain
@@ -79,7 +80,7 @@ type TicketsFeed(baseUri) =
  }
 
  // TODO add retries - consumer loop will not commence if this emits an exception
- member _.ReadTranches() : Async<Propulsion.Feed.TrancheId[]> = async {
- let! activeFcs = tickets.ActiveFcs()
+ member _.ReadTranches(ct) = task {
+ let! activeFcs = tickets.ActiveFcs() |> Async.startImmediateAsTask ct
  return [| for f in activeFcs -> TrancheId.ofFcId f |]
  }
diff --git a/feed-consumer/FeedConsumer.fsproj b/feed-consumer/FeedConsumer.fsproj
@@ -16,11 +16,11 @@
 
  <ItemGroup>
  <PackageReference Include="Argu" Version="6.1.1" />
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.CosmosStore.Prometheus" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
- <PackageReference Include="Propulsion.CosmosStore" Version="3.0.0-beta.7" />
- <PackageReference Include="Propulsion.Feed" Version="3.0.0-beta.7" />
+ <PackageReference Include="Propulsion.CosmosStore" Version="3.0.0-rc.1" />
+ <PackageReference Include="Propulsion.Feed" Version="3.0.0-rc.1" />
  <PackageReference Include="Serilog.Sinks.Async" Version="1.5.0" />
  <PackageReference Include="Serilog.Sinks.Console" Version="4.0.1" />
  </ItemGroup>

diff --git a/feed-consumer/Ingester.fs b/feed-consumer/Ingester.fs
@@ -1,5 +1,6 @@
 module FeedConsumerTemplate.Ingester
 
+open Propulsion.Internal
 open System
 open FeedConsumerTemplate.Domain
 
@@ -39,7 +40,7 @@ module PipelineEvent =
  ValueSome (fc, s |> Seq.map (fun e -> Unchecked.unbox<Item> e.Context))
  | _ -> ValueNone
 
-let handle maxDop struct (stream, span) = async {
+let handle maxDop stream span ct = Async.startImmediateAsTask ct <| async {
  match stream, span with
  | PipelineEvent.ItemsForFc (fc, items) ->
  // Take chunks of max 1000 in order to make handler latency be less 'lumpy'

diff --git a/feed-consumer/Program.fs b/feed-consumer/Program.fs
@@ -106,19 +106,21 @@ let build (args : Args.Arguments) =
  let handle = Ingester.handle args.TicketsDop
  let stats = Ingester.Stats(Log.Logger, args.StatsInterval, args.StateInterval)
  Propulsion.Streams.Default.Config.Start(Log.Logger, args.MaxReadAhead, args.FcsDop, handle, stats, args.StatsInterval)
- let pumpSource =
+ let source =
  let checkpoints = Propulsion.Feed.ReaderCheckpoint.CosmosStore.create Config.log (args.GroupId, args.CheckpointInterval) (context, cache)
  let feed = ApiClient.TicketsFeed args.BaseUri
  let source =
  Propulsion.Feed.FeedSource(
  Log.Logger, args.StatsInterval, args.SourceId, args.TailSleepInterval,
  checkpoints, sink, feed.Poll)
- source.Pump feed.ReadTranches
- sink, pumpSource
+ source.Start(fun ct -> source.Pump(feed.ReadTranches, ct))
+ sink, source
 
 let run args = async {
- let sink, pumpSource = build args
- do! Async.Parallel [ pumpSource; sink.AwaitWithStopOnCancellation() ] |> Async.Ignore<unit[]>
+ let sink, source = build args
+ use _ = sink
+ use _ = source
+ do! Async.Parallel [ source.AwaitWithStopOnCancellation(); sink.AwaitWithStopOnCancellation() ] |> Async.Ignore<unit[]>
  return if sink.RanToCompletion then 0 else 3
 }
 

diff --git a/feed-source/Domain/Domain.fsproj b/feed-source/Domain/Domain.fsproj
@@ -14,8 +14,8 @@
  </ItemGroup>
 
  <ItemGroup>
- <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.6" />
- <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.6" />
+ <PackageReference Include="Equinox.CosmosStore" Version="4.0.0-rc.7" />
+ <PackageReference Include="Equinox.MemoryStore" Version="4.0.0-rc.7" />
  <PackageReference Include="FsCodec.SystemTextJson" Version="3.0.0-rc.9" />
  </ItemGroup>