neurocore.skills.base.AsyncSkill

class neurocore.skills.base.AsyncSkill(name: str | None = None)

Bases: Skill

Skill whose process() is an async coroutine.

Subclass this instead of Skill when your process() needs to await. The executor detects coroutines automatically via inspect.iscoroutinefunction.

abstractmethod process(context: flowengine.FlowContext) → flowengine.FlowContext

Async:

Execute component logic.

The main processing method. Must be implemented by subclasses.

Parameters:

context – Current flow context with accumulated data

Returns:

Updated flow context (may be the same instance)