class Tumugi::Plugin::BigqueryDatasetTask

Public Instance Methods

output() click to toggle source
# File lib/tumugi/plugin/task/bigquery_dataset.rb, line 12
def output
  @output ||= Tumugi::Plugin::BigqueryDatasetTarget.new(project_id: project_id, dataset_id: dataset_id)
end
run() click to toggle source
# File lib/tumugi/plugin/task/bigquery_dataset.rb, line 16
def run
  log "Dataset: #{output}"
  if output.exist?
    log "skip: #{output} is already exists"
  else
    bq_client = output.client
    bq_client.insert_dataset(dataset_id, project_id: project_id)
    log "run: #{output}"
  end
end