Sha256: 100f799faa78259e6256e64019cfcdad1cb1dc399fad42a833cd2df2c46572d1
Contents?: true
Size: 1.56 KB
Versions: 11
Compression:
Stored size: 1.56 KB
Contents
module Isomorfeus
class << self
def cached_operation_classes
@cached_operation_classes ||= {}
end
def cached_operation_class(class_name)
return "::#{class_name}".constantize if Isomorfeus.development?
return cached_operation_classes[class_name] if cached_operation_classes.key?(class_name)
cached_operation_classes[class_name] = "::#{class_name}".constantize
end
if RUBY_ENGINE != 'opal'
attr_accessor :operation_timer_tasks
def valid_operation_class_names
@valid_operation_class_names ||= Set.new
end
def valid_operation_class_name?(class_name)
valid_operation_class_names.include?(class_name)
end
def add_valid_operation_class(klass)
class_name = klass.name
class_name = class_name.split('>::').last if class_name.start_with?('#<')
valid_operation_class_names << class_name
end
def pop_failed_tasks
failed_tasks = []
[Isomorfeus::Operation::DeferredTask, Isomorfeus::Operation::DailyTask].each do |task_class|
task_class.search(:state, 'failed').each do |task|
failed_tasks << task
task.destroy
end
end
failed_tasks
end
def all_tasks
all_tasks = []
[Isomorfeus::Operation::DeferredTask, Isomorfeus::Operation::DailyTask].each do |task_class|
task_class.search(:state, '*').each do |task|
all_tasks << task
end
end
all_tasks
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems