Sha256: 3e5282a1c006447a99baac582831e82c1ce949a8abd5ec035a206b977674ddee
Contents?: true
Size: 454 Bytes
Versions: 12
Compression:
Stored size: 454 Bytes
Contents
class MissionControl::Jobs::Worker
include ActiveModel::Model
attr_accessor :id, :name, :hostname, :last_heartbeat_at, :configuration, :raw_data
def initialize(queue_adapter: ActiveJob::Base.queue_adapter, **kwargs)
@queue_adapter = queue_adapter
super(**kwargs)
end
def jobs
@jobs ||= ActiveJob::JobsRelation.new(queue_adapter: queue_adapter).in_progress.where(worker_id: id)
end
private
attr_reader :queue_adapter
end
Version data entries
12 entries across 12 versions & 1 rubygems