keiro-dsl-0.17.0.0: test/conformance-process-reactions/Generated/ProcessReactions/ScalingReaction/Process.hs

{-# OPTIONS_GHC -Wno-missing-signatures #-}
-- @generated by keiro-dsl 0.17.0.0 (language keiro-dsl 6) from process reaction ScalingReaction; do not edit.
module Generated.ProcessReactions.ScalingReaction.Process
  ( ScalingReactionInput (..)
  , scalingReactionProcessName
  , scalingReactionCategory
  , scalingReactionProcessWorkerOptions
  , scalingReactionReactionVersion
  , scalingReactionReactionFingerprint
  , scalingReactionReact
  , scalingReactionProcessManager
  , scalingReactionRunProcessWorker
  ) where

import Data.Text (Text)
import Numeric.Natural (Natural)
import Generated.ProcessReactions.ScalingReaction.Input (ScalingReactionInput (..))
import ProcessReactions.ScalingReaction.ProcessHoles (decodeScalingReactionInput)
import Generated.ProcessReactions.IncidentSaga.Domain qualified as Saga
import Generated.ProcessReactions.IncidentSaga.EventStream (incidentSagaEventStream, IncidentSagaEventStreamDef)
import Generated.ProcessReactions.Incident.Domain qualified as Target
import Generated.ProcessReactions.Incident.EventStream (incidentCommandCategory, incidentEventStream)
import Generated.ProcessReactions.Nominals qualified as N
import Keiro.Command (DomainCommandHandler (..), SilentDomainDecision (..))
import Keiro.ProcessManager (PMCommand (..))
import Keiro.ProcessManager.Reaction qualified as Reaction
import Keiro.Stream qualified as Stream
import Keiro.ProcessManager (PoisonPolicy (..), RejectedCommandPolicy (..), WorkerOptions (..))
import Shibuya.Core.Ack (RetryDelay (..))

scalingReactionProcessName :: Text
scalingReactionProcessName = "scaling-reaction"

scalingReactionCategory :: Stream.StreamCategory IncidentSagaEventStreamDef
scalingReactionCategory = Stream.categoryUnsafe "scalingSaga"

scalingReactionProcessWorkerOptions :: WorkerOptions es msg
scalingReactionProcessWorkerOptions =
  WorkerOptions
    { poisonPolicy = PoisonHalt,
      rejectedCommandPolicy = RejectedHalt,
      transientRetryDelay = RetryDelay 5, -- matches defaultWorkerOptions; runtime tuning
      metrics = Nothing -- runtime configuration; install at call site
    }

scalingReactionReactionVersion :: Natural
scalingReactionReactionVersion = 1

scalingReactionReactionFingerprint :: Text
scalingReactionReactionFingerprint = "8329eab62dfa1917a468c914b9bbb7cae121b5d353656e69543f6aa95a43a14f"

scalingReactionCorrelate :: ScalingReactionInput -> Text
scalingReactionCorrelate input = case input of
  FanOut8Same { incidentId } -> (N.incidentIdText incidentId)
  FanOut32Same { incidentId } -> (N.incidentIdText incidentId)
  FanOut128Same { incidentId } -> (N.incidentIdText incidentId)
  FanOut8Distinct { incidentId } -> (N.incidentIdText incidentId)
  FanOut32Distinct { incidentId } -> (N.incidentIdText incidentId)
  FanOut128Distinct { incidentId } -> (N.incidentIdText incidentId)

scalingReactionReact :: ScalingReactionInput -> Reaction.ReactionPlan Saga.IncidentSagaCommand Target.IncidentCommand
scalingReactionReact input = case input of
  FanOut8Same { incidentId }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId })))], onAccepted = [] }
  FanOut32Same { incidentId }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId })))], onAccepted = [] }
  FanOut128Same { incidentId }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText incidentId)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = incidentId })))], onAccepted = [] }
  FanOut8Distinct { incidentId, target001, target002, target003, target004, target005, target006, target007, target008 }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target001)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target001 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target002)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target002 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target003)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target003 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target004)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target004 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target005)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target005 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target006)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target006 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target007)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target007 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target008)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target008 })))], onAccepted = [] }
  FanOut32Distinct { incidentId, target001, target002, target003, target004, target005, target006, target007, target008, target009, target010, target011, target012, target013, target014, target015, target016, target017, target018, target019, target020, target021, target022, target023, target024, target025, target026, target027, target028, target029, target030, target031, target032 }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target001)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target001 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target002)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target002 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target003)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target003 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target004)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target004 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target005)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target005 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target006)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target006 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target007)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target007 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target008)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target008 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target009)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target009 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target010)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target010 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target011)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target011 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target012)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target012 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target013)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target013 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target014)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target014 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target015)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target015 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target016)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target016 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target017)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target017 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target018)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target018 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target019)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target019 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target020)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target020 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target021)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target021 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target022)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target022 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target023)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target023 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target024)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target024 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target025)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target025 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target026)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target026 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target027)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target027 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target028)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target028 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target029)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target029 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target030)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target030 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target031)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target031 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target032)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target032 })))], onAccepted = [] }
  FanOut128Distinct { incidentId, target001, target002, target003, target004, target005, target006, target007, target008, target009, target010, target011, target012, target013, target014, target015, target016, target017, target018, target019, target020, target021, target022, target023, target024, target025, target026, target027, target028, target029, target030, target031, target032, target033, target034, target035, target036, target037, target038, target039, target040, target041, target042, target043, target044, target045, target046, target047, target048, target049, target050, target051, target052, target053, target054, target055, target056, target057, target058, target059, target060, target061, target062, target063, target064, target065, target066, target067, target068, target069, target070, target071, target072, target073, target074, target075, target076, target077, target078, target079, target080, target081, target082, target083, target084, target085, target086, target087, target088, target089, target090, target091, target092, target093, target094, target095, target096, target097, target098, target099, target100, target101, target102, target103, target104, target105, target106, target107, target108, target109, target110, target111, target112, target113, target114, target115, target116, target117, target118, target119, target120, target121, target122, target123, target124, target125, target126, target127, target128 }
    -> Reaction.AdvanceReaction { command = Saga.RecordCritical (Saga.RecordCriticalData { Saga.incidentId = incidentId }), followUps = [Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target001)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target001 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target002)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target002 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target003)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target003 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target004)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target004 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target005)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target005 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target006)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target006 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target007)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target007 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target008)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target008 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target009)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target009 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target010)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target010 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target011)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target011 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target012)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target012 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target013)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target013 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target014)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target014 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target015)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target015 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target016)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target016 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target017)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target017 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target018)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target018 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target019)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target019 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target020)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target020 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target021)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target021 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target022)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target022 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target023)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target023 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target024)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target024 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target025)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target025 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target026)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target026 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target027)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target027 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target028)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target028 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target029)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target029 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target030)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target030 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target031)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target031 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target032)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target032 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target033)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target033 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target034)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target034 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target035)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target035 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target036)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target036 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target037)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target037 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target038)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target038 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target039)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target039 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target040)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target040 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target041)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target041 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target042)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target042 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target043)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target043 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target044)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target044 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target045)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target045 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target046)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target046 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target047)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target047 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target048)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target048 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target049)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target049 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target050)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target050 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target051)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target051 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target052)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target052 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target053)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target053 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target054)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target054 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target055)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target055 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target056)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target056 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target057)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target057 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target058)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target058 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target059)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target059 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target060)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target060 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target061)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target061 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target062)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target062 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target063)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target063 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target064)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target064 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target065)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target065 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target066)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target066 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target067)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target067 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target068)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target068 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target069)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target069 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target070)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target070 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target071)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target071 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target072)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target072 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target073)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target073 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target074)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target074 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target075)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target075 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target076)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target076 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target077)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target077 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target078)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target078 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target079)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target079 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target080)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target080 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target081)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target081 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target082)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target082 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target083)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target083 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target084)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target084 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target085)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target085 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target086)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target086 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target087)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target087 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target088)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target088 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target089)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target089 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target090)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target090 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target091)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target091 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target092)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target092 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target093)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target093 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target094)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target094 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target095)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target095 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target096)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target096 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target097)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target097 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target098)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target098 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target099)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target099 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target100)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target100 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target101)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target101 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target102)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target102 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target103)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target103 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target104)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target104 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target105)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target105 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target106)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target106 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target107)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target107 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target108)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target108 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target109)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target109 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target110)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target110 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target111)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target111 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target112)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target112 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target113)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target113 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target114)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target114 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target115)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target115 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target116)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target116 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target117)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target117 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target118)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target118 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target119)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target119 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target120)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target120 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target121)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target121 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target122)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target122 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target123)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target123 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target124)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target124 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target125)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target125 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target126)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target126 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target127)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target127 }))), Reaction.FollowDispatch (PMCommand (Stream.entityStream incidentCommandCategory (N.incidentIdText target128)) (Target.EscalateIncident (Target.EscalateIncidentData { Target.incidentId = target128 })))], onAccepted = [] }

scalingReactionProcessManager =
  Reaction.ReactiveProcessManager
    { name = scalingReactionProcessName
    , correlate = scalingReactionCorrelate
    , sagaHandler = DomainCommandHandler { eventStream = incidentSagaEventStream, classifySilent = \_ -> SilentNoOp () }
    , streamFor = Stream.entityStream scalingReactionCategory
    , targetEventStream = incidentEventStream
    , targetProjections = const []
    , react = scalingReactionReact
    }

scalingReactionRunProcessWorker options adapter =
  Reaction.runReactiveProcessManagerWorkerWith
    scalingReactionProcessWorkerOptions
    options
    scalingReactionProcessManager
    adapter
    (\event -> case decodeScalingReactionInput event of Nothing -> Nothing; Just input -> Just (event, input))