PlanRunner

Value parameters

maxConcurrentNodes

Maximum number of nodes that can execute in parallel (default: 10). Used to prevent resource exhaustion in large DAGs. Follows LLM4S patterns:

• Uses AsyncResult[_] (Future[Result[_]]) for async operations
• Structured logging with MDC context
• Proper error types from OrchestrationError
• Result.safely for exception handling
• Standard Future combinators

Attributes

Note

MDC context is preserved across async boundaries using MDCContext utility.

Supports cancellation via CancellationToken for long-running operations.

Example

val runner = PlanRunner(maxConcurrentNodes = 5)
val token = CancellationToken()
val result = runner.execute(plan, Map("input" -> data), token)

Companion

object

Graph

Reset zoomHide graphShow graph

Supertypes

class Object

trait Matchable

class Any