Cyclium.DynamicWorkflow.InputResolver (Cyclium v0.1.6)

Copy Markdown View Source

Resolves declarative input_map paths against trigger and prior step data.

Used by dynamic workflows to compute step inputs without Elixir functions.

Path syntax

  • "trigger.order_id" — resolves trigger_ref["order_id"]
  • "prior.validate.classification.primary" — resolves prior[:validate][:classification]["primary"]
  • Any other value is treated as a static value and passed through as-is

Example

input_map = %{
  "order_id" => "trigger.order_id",
  "risk" => "prior.compliance_check.classification.primary",
  "mode" => "fast"
}

InputResolver.resolve(input_map, trigger_ref, prior)
# => %{"order_id" => "abc123", "risk" => "high", "mode" => "fast"}

Summary

Functions

Resolve an input_map against trigger_ref and prior step results.

Functions

resolve(input_map, trigger_ref, prior)

Resolve an input_map against trigger_ref and prior step results.

Returns a map with the same keys as input_map, values resolved from paths.