lib/taskinator/api.rb in taskinator-0.4.2 vs lib/taskinator/api.rb in taskinator-0.4.3

- old
+ new

@@ -11,22 +11,31 @@ end def each(&block) return to_enum(__method__) unless block_given? + identifiers = Taskinator.redis do |conn| + conn.smembers(@processes_list_key) + end + instance_cache = {} - Taskinator.redis do |conn| - uuids = conn.smembers(@processes_list_key) - uuids.each do |uuid| - yield Process.fetch(uuid, instance_cache) - end + identifiers.each do |identifier| + yield Process.fetch(identifier, instance_cache) end end def size Taskinator.redis do |conn| conn.scard(@processes_list_key) end end + end + + def self.find_process(identifier) + Process.fetch(identifier) + end + + def self.find_task(identifier) + Task.fetch(identifier) end end end