Class: Taski::Execution::Coordinator

Inherits:
Object
  • Object
show all
Defined in:
lib/taski/execution/coordinator.rb

Instance Method Summary collapse

Constructor Details

#initialize(registry:, analyzer:) ⇒ Coordinator

Returns a new instance of Coordinator.



6
7
8
9
 
# File 'lib/taski/execution/coordinator.rb', line 6

def initialize(registry:, analyzer:)
  @registry = registry
  @analyzer = analyzer
end

Instance Method Details

#start_clean_dependencies(task_class) ⇒ Object

Parameters:

  • task_class (Class) —

    The task class whose dependencies should be cleaned



22
23
24
25
26
27
28
29
 
# File 'lib/taski/execution/coordinator.rb', line 22

def start_clean_dependencies(task_class)
  dependencies = get_dependencies(task_class)
  return if dependencies.empty?

  dependencies.each do |dep_class|
    start_dependency_clean(dep_class)
  end
end

#start_dependencies(task_class) ⇒ Object

Parameters:

  • task_class (Class) —

    The task class whose dependencies should be started



12
13
14
15
16
17
18
19
 
# File 'lib/taski/execution/coordinator.rb', line 12

def start_dependencies(task_class)
  dependencies = get_dependencies(task_class)
  return if dependencies.empty?

  dependencies.each do |dep_class|
    start_dependency_execution(dep_class)
  end
end