class Minitest::Distributed::PendingExecution
Public Class Methods
from_xpending(xpending_result)
click to toggle source
# File lib/minitest/distributed/enqueued_runnable.rb, line 20 def self.from_xpending(xpending_result) new( worker_id: xpending_result.fetch("consumer"), entry_id: xpending_result.fetch("entry_id"), elapsed_time_ms: xpending_result.fetch("elapsed"), attempt: xpending_result.fetch("count"), ) end
Public Instance Methods
attempt_id()
click to toggle source
# File lib/minitest/distributed/enqueued_runnable.rb, line 15 def attempt_id "#{entry_id}/#{attempt}" end