Interface: EngineBatchModel

Defined in: packages/workflow-engine/src/ai/batch/model.ts:89

Properties

modelId

readonly modelId: string

Defined in: packages/workflow-engine/src/ai/batch/model.ts:91

---

provider

readonly provider: string

Defined in: packages/workflow-engine/src/ai/batch/model.ts:90

---

recovery?

readonly optional recovery?: EngineBatchRecovery

Defined in: packages/workflow-engine/src/ai/batch/model.ts:93

How, if at all, a crashed submit can be recovered on this transport.

Methods

adopt()?

optional adopt(externalKey, opts?): Promise<EngineBatchRef & EngineBatchStatus | null>

Defined in: packages/workflow-engine/src/ai/batch/model.ts:104

Find a batch this engine already created under externalKey, if one exists. Implemented only when recovery is "metadata". Returns null when the provider has no such batch — which, on a reclaim, means the crashed worker died before the provider accepted the creation.

Parameters

externalKey

string

opts?

abortSignal?

AbortSignal

headers?

Record<string, string>

Returns

Promise<EngineBatchRef & EngineBatchStatus | null>

---

results()

results(ref, opts?): AsyncIterable<EngineBatchItemResult>

Defined in: packages/workflow-engine/src/ai/batch/model.ts:115

Parameters

ref

EngineBatchRef

opts?

abortSignal?

AbortSignal

headers?

Record<string, string>

Returns

AsyncIterable<EngineBatchItemResult>

---

start()

start(requests, opts?): Promise<EngineBatchRef & EngineBatchStatus>

Defined in: packages/workflow-engine/src/ai/batch/model.ts:94

Parameters

requests

EngineBatchRequest[]

opts?

EngineBatchStartOptions

Returns

Promise<EngineBatchRef & EngineBatchStatus>

---

status()

status(ref, opts?): Promise<EngineBatchStatus>

Defined in: packages/workflow-engine/src/ai/batch/model.ts:108

Parameters

ref

EngineBatchRef

opts?

abortSignal?

AbortSignal

headers?

Record<string, string>

Returns

Promise<EngineBatchStatus>