runs

active(options?: { pageSize: number; pageToken: string }): Promise<Page<ActiveConversationRun>>

activeBySession(sessionIds: readonly string[]): Promise<ActiveConversationRun[]>

cancel(runId: string): Promise<void>

create(workflowId: string | number, body: object, options?: { idempotencyKey: string }): AgentRunStream

const stream = client.workflows.runs.create(workflowId, {
  message: 'Summarize yesterday\'s sales',
  sessionId: 'conv-abc',
})
for await (const event of stream) {
  if (event.type === 'token') process.stdout.write(event.content)
  if (event.type === 'done') break
}

createModus(body: object, options?: { idempotencyKey: string }): AgentRunStream

createScope(scopeId: string | number, body: object, options?: { idempotencyKey: string }): AgentRunStream

editQueued(runId: string): Promise<void>

events(runId: string): Promise<unknown>

get(workflowId: string | number, runId: string, options?: { temporalRunId: string }): Promise<object>

interrupt(runId: string): Promise<void>

list(workflowId: string | number, options?: { pageSize: number; pageToken: string; status: RunStatus; timeframe: RunTimeframe; approvalScope: ApprovalScope; search: string }): Promise<Page<object>>

resume(runId: string, body: object, options?: { idempotencyKey: string }): AgentRunStream

stream(runId: string, options?: { lastEventId: string }): AgentRunStream

const stream = client.workflows.runs.stream(runId, { lastEventId: checkpoint })
for await (const event of stream) {
  if (event.type === 'token') process.stdout.write(event.content)
}