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