module Dag::Client::Job

Public Instance Methods

job(job_id) click to toggle source
# File lib/dag/client/job.rb, line 11
def job(job_id)
  job_info = @api.query_info(job_id)
  Dag::Job.new(@api, job_info)
end
job_cancel(job_id) click to toggle source
# File lib/dag/client/job.rb, line 24
def job_cancel(job_id)

  job = job(job_id)
  job.validate_cancel_condition
  @api.query_cancel(job_id)
end
job_download_urls(job_id) click to toggle source
# File lib/dag/client/job.rb, line 50
def job_download_urls(job_id)
  job = job(job_id)
  job.download_urls
end
job_log(job_id) click to toggle source
# File lib/dag/client/job.rb, line 16
def job_log(job_id)

  job = job(job_id)
  job.validate_log_condition
  log_info = @api.query_log(job_id)
  log_info ? log_info['log'] : ''
end
jobs() click to toggle source
# File lib/dag/client/job.rb, line 7
def jobs
  Dag::JobCollection.new(@api)
end
query(query: '', output_format: 'csv', output_resource_path: '', label: '') click to toggle source

parameters ==

  • query - query

  • output_format - 'csv' or 'tsv'

  • output_resource_path - “${bucketname}/${output_object}”

  • label - label

# File lib/dag/client/job.rb, line 37
def query(query: '', output_format: 'csv', output_resource_path: '', label: '')
  validate_cluster

  select_info = @api.query(query: query,
                           output_format: output_format,
                           output_resource_path: output_resource_path,
                           cluster_name: @cluster_name,
                           label: label)
  job_id = select_info['queryId']

  job(job_id)
end