@persistent-ai/fireflow-executor / server / InMemoryTaskQueue

Class: InMemoryTaskQueue

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:20

In-memory implementation of ITaskQueue for local development Uses a simple array-based queue with direct execution

Implements

• ITaskQueue

Constructors

Constructor

new InMemoryTaskQueue(): InMemoryTaskQueue

Returns

InMemoryTaskQueue

Methods

close()

close(): Promise<void>

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:78

Close the queue and cleanup resources

Returns

Promise<void>

Implementation of

ITaskQueue.close

---

consumeTasks()

consumeTasks(handler): Promise<void>

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:44

Start consuming tasks from the queue Handler is called for each task with optional context for manual offset management

Parameters

handler

TaskHandler

Returns

Promise<void>

Implementation of

ITaskQueue.consumeTasks

---

getPendingCount()

getPendingCount(): Promise<number>

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:74

Get the number of pending tasks (if available)

Returns

Promise<number>

Implementation of

ITaskQueue.getPendingCount

---

publishTask()

publishTask(task): Promise<WorkflowHandle<any>>

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:28

Publish an execution task to the queue

Parameters

task

ExecutionTask

Returns

Promise<WorkflowHandle<any>>

Implementation of

ITaskQueue.publishTask

---

stopConsuming()

stopConsuming(): Promise<void>

Defined in: packages/fireflow-executor/server/implementations/local/InMemoryTaskQueue.ts:61

Stop consuming tasks

Returns

Promise<void>

Implementation of

ITaskQueue.stopConsuming