class Tumugi::Plugin::BigqueryCopyTask

Public Instance Methods

completed?() click to toggle source
Calls superclass method
# File lib/tumugi/plugin/task/bigquery_copy.rb, line 26
def completed?
  if force_copy && !finished?
    false
  else
    super
  end
end
output() click to toggle source
# File lib/tumugi/plugin/task/bigquery_copy.rb, line 18
def output
  return @output if @output

  opts = { dataset_id: dest_dataset_id, table_id: dest_table_id }
  opts[:project_id] = dest_project_id if dest_project_id
  @output = Tumugi::Plugin::BigqueryTableTarget.new(opts)
end
run() click to toggle source
# File lib/tumugi/plugin/task/bigquery_copy.rb, line 34
def run
  log "Source: bq://#{src_project_id}/#{src_dataset_id}/#{src_table_id}"
  log "Destination: #{output}"

  bq_client = output.client
  opts = { wait: wait }
  opts[:src_project_id] = src_project_id if src_project_id
  opts[:dest_project_id] = dest_project_id if dest_project_id
  bq_client.copy(src_dataset_id, src_table_id, dest_dataset_id, dest_table_id, opts)
end