Sha256: 63d562e688aec0016ccde90ee18f147643a5a9dbe7bffa0e3d1833040f0e5d25
Contents?: true
Size: 614 Bytes
Versions: 38
Compression:
Stored size: 614 Bytes
Contents
# encoding: utf-8
require 'mutx'
require 'sidetiq'
#require 'sidekiq/testing/inline'
module Mutx
module Workers
class UpdateStarted
include Sidekiq::Worker
include Sidetiq::Schedulable
recurrence { minutely(2) }
def perform
started_result = nil
started_result = Mutx::Database::MongoConnector.started!
started_result.each do |line|
puts Mutx::API::Execution.reset(line["_id"])
end
puts "- ==== NO Started Results Founded ====" if started_result.eql? []
##Mutx::Database::MongoConnector.force_close
end
end#class
end
end
Version data entries
38 entries across 38 versions & 1 rubygems