pub(all) struct AnalysisJobInput {
  plan : 
@vectie/moonfish/planning.AnalysisPlan
AnalysisPlan
  bundle : 
@vectie/moonfish/workflow.AnalysisRunBundle
AnalysisRunBundle?
  cancel_reason : String?
  failure_message : String?
  retry_policy : RetryPolicy
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum AnalysisJobOutcome {
  ReadyToStart
  AwaitingMarketData
  Completed
  Cancelled
  Failed
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct AnalysisJobState {
  run_id : String
  outcome : AnalysisJobOutcome
  failure_kind : JobFailureKind?
  bundle_status : 
@vectie/moonfish/workflow.AnalysisRunStatus
AnalysisRunStatus?
  can_start : Bool
  can_retry : Bool
  partial_record_available : Bool
  retry_policy : RetryPolicy
  event_count : Int
  review_count : Int
  blocking_review_count : Int
  artifact_paths : Array[String]
  events : Array[
@vectie/moonfish/routine.RoutineEvent
RoutineEvent]
  message : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) enum JobFailureKind {
  PlanningFailed
  MarketDataUnavailable
  ModelGatewayUnavailable
  ValidationFailed
  RuntimeFailed
  OperatorCancelled
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

pub(all) struct RetryPolicy {
  max_attempts : Int
  semantic_max_attempts : Int
  retry_stage2 : Bool
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug, 
@moonbitlang/core/json.FromJson
FromJson)

fn analysis_job_input(plan : 
@vectie/moonfish/planning.AnalysisPlan
AnalysisPlan, bundle? : 
@vectie/moonfish/workflow.AnalysisRunBundle
AnalysisRunBundle, cancel_reason? : String, failure_message? : String, retry_policy? : RetryPolicy) -> AnalysisJobInput

fn default_retry_policy(max_attempts? : Int, semantic_max_attempts? : Int, retry_stage2? : Bool) -> RetryPolicy

fn prepare_analysis_job(input : AnalysisJobInput) -> AnalysisJobState