class KubeQueue::Executor

Public Instance Methods

enqueue(job) click to toggle source
# File lib/kube_queue/executor.rb, line 5
def enqueue(job)
  resource = if job.scheduled_at
               KubeQueue.client.create_cron_job(job.manifest)
             else
               KubeQueue.client.create_job(job.manifest)
             end

  job.resource = resource
  resource
end