Module: Dag::Client::Job

Included in:
Dag::Client
Defined in:
lib/dag/client/job.rb

Instance Method Summary collapse

Instance Method Details

#job(job_id) ⇒ Object 



11
12
13
14
 
# 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) ⇒ Object 



24
25
26
27
28
29
 
# 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) ⇒ Object 



50
51
52
53
 
# 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) ⇒ Object 



16
17
18
19
20
21
22
 
# 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 ⇒ Object 



7
8
9
 
# File 'lib/dag/client/job.rb', line 7

def jobs
  Dag::JobCollection.new(@api)
end

#query(query: '', output_format: 'csv', output_resource_path: '', label: '') ⇒ Object

parameters ==

  • query - query

  • output_format - ‘csv’ or ‘tsv’

  • output_resource_path - “$bucketname/$output_object”

  • label - label



37
38
39
40
41
42
43
44
45
46
47
48
 
# 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