pub struct CommandAdapter {
  run : (String, String?, Map[String, String]) -> CommandResult
}

pub struct CommandResult {
  code : Int
  stdout : String
  stderr : String
}

pub struct ExternalInputParseResult {
  values : Map[String, String]
  errors : Array[String]
}

pub struct FlowCacheStoreResult {
  entries : Map[String, String]
  issues : Array[String]
}

pub struct FlowExecutionResult {
  ok : Bool
  state : String
  order : Array[String]
  steps : Array[FlowStep]
  issues : Array[String]
}

pub struct FlowIr {
  name : String
  max_parallel : Int
  nodes : Array[FlowNode]
  tasks : Array[FlowTask]
  entry_targets : Array[String]
}

pub struct FlowNode {
  id : String
  required : Bool
  depends_on : Array[String]
}

pub struct FlowStep {
  id : String
  status : String
  required : Bool
  message : String
}

pub struct FlowTask {
  id : String
  node : String
  cmd : String
  needs : Array[String]
  required : Bool
  srcs : Array[String]
  outs : Array[String]
  env : Map[String, String]
  cwd : String
  trigger_mode : String
}

pub struct FlowTaskCacheDecision {
  id : String
  cache_key : String
  fingerprint : String
  hit : Bool
}

pub struct FlowTaskCachePlanResult {
  decisions : Array[FlowTaskCacheDecision]
  issues : Array[String]
}

pub struct FlowTaskCacheWritebackResult {
  entries : Map[String, String]
  updated : Array[String]
  issues : Array[String]
}

pub struct FsAdapter {
  read_text : (String) -> String?
  write_text : (String, String) -> Bool
  exists : (String) -> Bool
  list_paths : () -> Array[String]
}

pub struct StarlarkParseResult {
  ir : FlowIr
  errors : Array[String]
}

pub struct WorkflowAdapter {
  fs : FsAdapter
  cmd : CommandAdapter
}

fn command_failure(code? : Int, stdout? : String, stderr? : String) -> CommandResult

fn command_success(stdout? : String, stderr? : String) -> CommandResult

fn entry_targets_for_changed_paths(ir : FlowIr, changed_paths : Array[String]) -> Array[String]

fn execute(text : String, run_task : (FlowTask) -> (Bool, String)) -> FlowExecutionResult

fn execute_from_fs(path : String, adapter : WorkflowAdapter) -> FlowExecutionResult

fn execute_from_fs_with_cli_env(path : String, adapter : WorkflowAdapter, cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> FlowExecutionResult

fn execute_from_fs_with_inputs(path : String, adapter : WorkflowAdapter, external_inputs : Map[String, String]) -> FlowExecutionResult

fn execute_ir(ir : FlowIr, run_task : (FlowTask) -> (Bool, String)) -> FlowExecutionResult

fn execute_ir_for_changed_paths(ir : FlowIr, changed_paths : Array[String], run_task : (FlowTask) -> (Bool, String)) -> FlowExecutionResult

fn execute_ir_with_adapter(ir : FlowIr, adapter : WorkflowAdapter) -> FlowExecutionResult

fn execute_with_cli_env(text : String, cli_args : Array[String], env : Map[String, String], run_task : (FlowTask) -> (Bool, String), cli_flag? : String, env_prefix? : String) -> FlowExecutionResult

fn execute_with_inputs(text : String, external_inputs : Map[String, String], run_task : (FlowTask) -> (Bool, String)) -> FlowExecutionResult

fn expand_affected_nodes(nodes : Array[FlowNode], initial : Map[String, Bool]) -> Map[String, Bool]

fn flow_cache_key(task : String, node_id : String) -> String

fn flow_fingerprint(task : String, task_cmd : String, node : FlowNode, signatures : Map[String, String]) -> String

fn flow_task_fingerprint(task : FlowTask, node : FlowNode, signatures : Map[String, String]) -> String

fn graph_issues(nodes : Array[FlowNode]) -> Array[String]

fn has_dependency_cycle(nodes : Array[FlowNode]) -> Bool

fn ir_issues(ir : FlowIr) -> Array[String]

fn new_ir(name : String, nodes : Array[FlowNode], tasks : Array[FlowTask], entry_targets? : Array[String], max_parallel? : Int) -> FlowIr

fn new_node(id : String, depends_on : Array[String], required? : Bool) -> FlowNode

fn new_task(id : String, node : String, cmd : String, needs : Array[String], required? : Bool, srcs? : Array[String], outs? : Array[String], env? : Map[String, String], cwd? : String, trigger_mode? : String) -> FlowTask

fn new_task_cache_plan_result(decisions : Array[FlowTaskCacheDecision], issues : Array[String]) -> FlowTaskCachePlanResult

fn new_task_cache_writeback_result(entries : Map[String, String], updated : Array[String], issues : Array[String]) -> FlowTaskCacheWritebackResult

fn parse(text : String) -> StarlarkParseResult

fn parse_external_inputs(cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> ExternalInputParseResult

fn parse_from_fs(path : String, adapter : WorkflowAdapter) -> StarlarkParseResult

fn parse_from_fs_with_cli_env(path : String, adapter : WorkflowAdapter, cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> StarlarkParseResult

fn parse_from_fs_with_inputs(path : String, adapter : WorkflowAdapter, external_inputs : Map[String, String]) -> StarlarkParseResult

fn parse_with_cli_env(text : String, cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> StarlarkParseResult

fn parse_with_inputs(text : String, external_inputs : Map[String, String]) -> StarlarkParseResult

fn plan_task_cache(ir : FlowIr, signatures : Map[String, String], cache_entries : Map[String, String]) -> FlowTaskCachePlanResult

fn plan_task_cache_from_fs(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String]) -> FlowTaskCachePlanResult

fn plan_task_cache_from_fs_with_cli_env(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String], cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> FlowTaskCachePlanResult

fn plan_task_cache_from_fs_with_inputs(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String], external_inputs : Map[String, String]) -> FlowTaskCachePlanResult

fn read_flow_cache_store(path : String, adapter : WorkflowAdapter) -> FlowCacheStoreResult

fn render_task_cache_plan_json(result : FlowTaskCachePlanResult) -> String

fn render_task_cache_writeback_json(result : FlowTaskCacheWritebackResult) -> String

fn topological_nodes(nodes : Array[FlowNode]) -> Array[FlowNode]

fn write_execution_report(path : String, result : FlowExecutionResult, adapter : WorkflowAdapter) -> Bool

fn write_flow_cache_store(path : String, entries : Map[String, String], adapter : WorkflowAdapter) -> Bool

fn write_task_cache_plan_json(path : String, result : FlowTaskCachePlanResult, adapter : WorkflowAdapter) -> Bool

fn writeback_task_cache(ir : FlowIr, signatures : Map[String, String], cache_entries : Map[String, String], successful_task_ids : Array[String]) -> FlowTaskCacheWritebackResult

fn writeback_task_cache_from_fs(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String], successful_task_ids : Array[String]) -> FlowTaskCacheWritebackResult

fn writeback_task_cache_from_fs_with_cli_env(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String], successful_task_ids : Array[String], cli_args : Array[String], env : Map[String, String], cli_flag? : String, env_prefix? : String) -> FlowTaskCacheWritebackResult

fn writeback_task_cache_from_fs_with_inputs(path : String, adapter : WorkflowAdapter, signatures : Map[String, String], cache_entries : Map[String, String], successful_task_ids : Array[String], external_inputs : Map[String, String]) -> FlowTaskCacheWritebackResult