lib/embulk/output/bigquery/bigquery_client.rb in embulk-output-bigquery-0.3.5 vs lib/embulk/output/bigquery/bigquery_client.rb in embulk-output-bigquery-0.3.6
- old
+ new
@@ -195,10 +195,12 @@
# open_timeout_sec: @task['open_timeout_sec']
# },
}
Embulk.logger.debug { "embulk-output-bigquery: insert_job(#{@project}, #{body}, #{opts})" }
response = client.insert_job(@project, body, opts)
- unless @task['is_skip_job_result_check']
+ if @task['is_skip_job_result_check']
+ response
+ else
response = wait_load('Load', response)
end
rescue Google::Apis::ServerError, Google::Apis::ClientError, Google::Apis::AuthorizationError => e
response = {status_code: e.status_code, message: e.message, error_class: e.class}
Embulk.logger.error {