Sha256: c6043f77f42348c88371f71360960ace01bedb2c6dcd9db3827973281d798409
Contents?: true
Size: 441 Bytes
Versions: 5
Compression:
Stored size: 441 Bytes
Contents
class MissionControl::Jobs::RecurringTask
include ActiveModel::Model
attr_accessor :id, :job_class_name, :arguments, :schedule, :last_enqueued_at
def initialize(queue_adapter: ActiveJob::Base.queue_adapter, **kwargs)
@queue_adapter = queue_adapter
super(**kwargs)
end
def jobs
ActiveJob::JobsRelation.new(queue_adapter: queue_adapter).where(recurring_task_id: id)
end
private
attr_reader :queue_adapter
end
Version data entries
5 entries across 5 versions & 1 rubygems