Function driveById

packages/infra/src/WorkflowEngineCosmos.ts:441–450

(executionId: string)

    })

  const driveById = (executionId: string): Effect.Effect<void> =>
    Effect.gen(function*() {
      const stateOpt = yield* readExec(executionId)
      if (Option.isNone(stateOpt)) return
      const state = stateOpt.value
      const entry = workflows.get(state.workflowName)
      if (!entry) return
      const payload = yield* decodePayload(entry.workflow, state.payload)
      yield* drive(executionId, payload, state.parent, entry)
    })

  // --- Clock firing -----------------------------------------------------
  // Persist deferred completion (first-writer-wins via createIfMissing),