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

Interface: ITaskQueue

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:38

Interface for task queue implementations Handles distribution of execution tasks to workers

Properties

close

close: () => Promise<void>

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:63

Close the queue and cleanup resources

Returns

Promise<void>

---

consumeTasks

consumeTasks: (handler) => Promise<void>

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:48

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>

---

getPendingCount?

optional getPendingCount?: () => Promise<number>

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:58

Get the number of pending tasks (if available)

Returns

Promise<number>

---

publishTask

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

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:42

Publish an execution task to the queue

Parameters

task

ExecutionTask

Returns

Promise<WorkflowHandle<any>>

---

stopConsuming

stopConsuming: () => Promise<void>

Defined in: packages/fireflow-executor/server/interfaces/ITaskQueue.ts:53

Stop consuming tasks

Returns

Promise<void>