Sha256: dd247342f2ce0f981151b1fb49ff9730415b26c931fe0211d254e8ed49debad5
Contents?: true
Size: 1.9 KB
Versions: 11
Compression:
Stored size: 1.9 KB
Contents
module Logical::Naf::ConstructionZone
class Proletariat
def create_job(parameters, affinities, prerequisites)
::Naf::HistoricalJob.transaction do
historical_job = create_historical_job(parameters, affinities, prerequisites)
queued_job = create_queued_job(historical_job)
return historical_job
end
end
def create_historical_job(parameters, affinities, prerequisites)
::Naf::HistoricalJob.transaction do
historical_job = ::Naf::HistoricalJob.create!(parameters)
affinities.each do |affinity|
::Naf::HistoricalJobAffinityTab.create(affinity.merge(historical_job_id: historical_job.id))
end
historical_job.verify_prerequisites(prerequisites)
prerequisites.each do |prerequisite|
::Naf::HistoricalJobPrerequisite.create({
historical_job_id: historical_job.id,
prerequisite_historical_job_id: prerequisite.id
})
end
return historical_job
end
end
def create_queued_job(historical_job)
queued_job = ::Naf::QueuedJob.new(application_id: historical_job.application_id,
application_type_id: historical_job.application_type_id,
command: historical_job.command,
application_run_group_restriction_id: historical_job.application_run_group_restriction_id,
application_run_group_name: historical_job.application_run_group_name,
application_run_group_limit: historical_job.application_run_group_limit,
priority: historical_job.priority)
queued_job.id = historical_job.id
queued_job.save!
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems