director/lib/director/job_runner.rb
def run_checkpointing
      Thread.new do
        with_thread_name("task:#{@task.id}-checkpoint") do
          while true
            sleep(Config.task_checkpoint_interval)
            checkpoint
          end
        end
      end
    end
# Spawns a thread that periodically updates task checkpoint time.
# There is no need to kill this thread as job execution lifetime is the
# same as Resque worker process lifetime.
# @return [Thread] Checkpoint thread
Spawns a thread that periodically updates task checkpoint time.
There is no need to kill this thread as job execution lifetime is the
same as Resque worker process lifetime.
Spawns a thread that periodically updates task checkpoint time . There is no need to kill this thread as job execution lifetime is the same as Resque worker process lifetime .
def run_checkpointing
      Thread.new do
        with_thread_name("task:#{@task.id}-checkpoint") do
          while true
            sleep(Config.task_checkpoint_interval)
            checkpoint
          end
        end
      end
    end
def run_checkpointing Thread . new do with_thread_name ( "task:#{@task.id}-checkpoint" ) do while true sleep ( Config . task_checkpoint_interval ) checkpoint end end end end
Spawns a thread that periodically updates task checkpoint time.
Spawns a thread that periodically updates task checkpoint time .
None
Thread