Function ensureSuccess

packages/cluster/src/ClusterWorkflowEngine.ts:587–592

(effect: Effect.Effect<A, E, R>)

)

const ensureSuccess = <A, E, R>(effect: Effect.Effect<A, E, R>) =>
  effect.pipe(
    Effect.sandbox,
    Effect.retry(retryPolicy),
    Effect.orDie
  )

const ActivityRpc = Rpc.make("activity", {
  payload: {