class Croupier::Task

• Croupier::Task
• Reference
• Object

Overview

A Task is an object that may generate output

It has a Proc which is executed when the task is run It can have zero or more inputs It has zero or more outputs Tasks are connected by dependencies, where one task's output is another's input

Included Modules

• YAML::Serializable
• YAML::Serializable::Strict

Defined in:

task.cr

Constructors

• .new(ctx : YAML::ParseContext, node : YAML::Nodes::Node)
• .new(outputs : Array(String) = [] of String, inputs : Array(String) = [] of String, no_save : Bool = false, id : String | Nil = nil, always_run : Bool = false, mergeable : Bool = true, &block : TaskProc)
• .new(outputs : Array(String) = [] of String, inputs : Array(String) = [] of String, proc : TaskProc | Nil = nil, no_save : Bool = false, id : String | Nil = nil, always_run : Bool = false, mergeable : Bool = true)
• .new(output : String | Nil = nil, inputs : Array(String) = [] of String, no_save : Bool = false, id : String | Nil = nil, always_run : Bool = false, mergeable : Bool = true, &block : TaskProc)
• .new(output : String | Nil = nil, inputs : Array(String) = [] of String, proc : TaskProc | Nil = nil, no_save : Bool = false, id : String | Nil = nil, always_run : Bool = false, mergeable : Bool = true)

  Create a task with zero or one outputs.

Instance Method Summary

• #always_run=(always_run : Bool)
• #always_run? : Bool
• #id : String
• #id=(id : String)
• #inputs : Set(String)
• #inputs=(inputs : Set(String))
• #keys

  Under what keys should this task be registered with TaskManager

• #merge(other : Task)

  Merge two tasks.

• #mergeable=(mergeable : Bool)
• #mergeable? : Bool
• #no_save=(no_save : Bool)
• #no_save? : Bool
• #outputs : Array(String)
• #outputs=(outputs : Array(String))
• #procs : Array(TaskProc)
• #procs=(procs : Array(TaskProc))
• #ready?(run_all = false)

  A task is ready if it is stale and not waiting for anything

• #run

  Executes the proc for the task

• #stale : Bool
• #stale=(stale : Bool)
• #stale?

  ameba:disable Metrics/CyclomaticComplexity

• #to_s(io)
• #waiting_for

  For inputs that are tasks, we check if they are stale For inputs that are not tasks, they should exist as files If any inputs don't fit those criteria, they are being waited for.

Constructor Detail

Instance Method Detail