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