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