Method: Fasten::Runner#receive_jobs_tasks_thread

Defined in:
lib/fasten/runner.rb

#receive_jobs_tasks_thread(items) ⇒ Object 



153
154
155
156
157
158
159
160
161
162
163
164
165
 
# File 'lib/fasten/runner.rb', line 153

def receive_jobs_tasks_thread(items)
  items&.each do |task|
    tasks.running.delete task

    task.worker.running_task = task.worker.state = nil

    tasks.update task
    stats_add_entry(task.state, task)

    log_fin task, done_counters
    ui.force_clear
  end
end