Skip to main content

Module task

Module task 

Source

Structs§

Tagged
A value wrapper that carries arbitrary string metadata alongside the inner value.
TaggedMeta
Lightweight metadata carrier that tasks can attach to any Arc<dyn Value> when they need to propagate node_set without wrapping in Tagged<T>.
TaskInfo
A Task bundled with optional per-task configuration.

Enums§

Task
A single reusable unit of work in a cognee pipeline.
TaskCall
The pending (or already-resolved) output of Task::call.
TypedTask
A typed pipeline task whose input and output types are tracked at the type level.

Traits§

Value
Type-erased value passed between pipeline tasks.

Functions§

downcast_value
Attempt to downcast a Box<dyn Value> to a concrete type.
extract_node_set
Try to extract a node_set metadata value from an Arc<dyn Value>.

Type Aliases§

AsyncBatchFn
Async batch task: slice of values in → one value out (via a future).
AsyncFn
Async task: one value in → one value out (via a future).
AsyncStreamBatchFn
Async batch task: slice of values in → async stream of values out.
AsyncStreamFn
Async task: one value in → async stream of values out.
SyncBatchFn
Sync batch task: slice of values in → one value out.
SyncFn
Sync task: one value in → one value out.
SyncIterBatchFn
Sync batch task: slice of values in → lazy iterator of values out.
SyncIterFn
Sync task: one value in → lazy iterator of values out.
TaskError
Boxed error returned by a failing task.
ValueIter
Boxed, type-erased iterator yielded by SyncIter tasks.
ValueStream
Boxed, type-erased async stream yielded by AsyncStream tasks.