lib/ripe/worker_controller/syncer.rb
##
# Fetch a list of completed workers from the running jobs: these are jobs
# that were previously marked as active, blocked or idle that can no
# be found on the compute cluster queue.
#
# @return [void]
Fetch a list of completed workers from the running jobs: these are jobs
that were previously marked as active, blocked or idle that can no
be found on the compute cluster queue.
Fetch a list of completed workers from the running jobs : these are jobs that were previously marked as active blocked or idle that can no be found on the compute cluster queue .
def fetch_completed_jobs
        running_job_ids = @running_jobs.map { |job| job[:moab_id] }
        running_workers = DB::Worker.where('status in (:statuses)',
                                           :statuses => ['active', 'idle', 'blocked'])
        @completed_workers = running_workers.select do |worker|
          !running_job_ids.include?(worker.moab_id) &&
            !worker.cancelled? && worker.user == `whoami`.chomp
        end
      end
def fetch_completed_jobs running_job_ids = @running_jobs . map { | job | job [ :moab_id ] } running_workers = DB :: Worker . where ( 'status in (:statuses)' , :statuses => [ 'active' , 'idle' , 'blocked' ] ) @completed_workers = running_workers . select do | worker | ! running_job_ids . include? ( worker . moab_id ) && ! worker . cancelled? && worker . user == ` whoami ` . chomp end end
Fetch a list of completed workers from the running jobs: these are jobs
that were previously marked as active, blocked or idle that can no
be found on the compute cluster queue.
Fetch a list of completed workers from the running jobs : these are jobs that were previously marked as active blocked or idle that can no be found on the compute cluster queue .
None
void