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 {