Merge pull request #90 from nownabe/error_result

Check error_result to judge job results instead of errors

Author: sonots

lib/embulk/output/bigquery/bigquery_client.rb

@@ -330,10 +330,13 @@ def wait_load(kind, response)
             end
           end
 
-          # cf. http://www.rubydoc.info/github/google/google-api-ruby-client/Google/Apis/BigqueryV2/JobStatus#errors-instance_method
           # `errors` returns Array<Google::Apis::BigqueryV2::ErrorProto> if any error exists.
+          _errors = _response.status.errors
+
+          # cf. http://www.rubydoc.info/github/google/google-api-ruby-client/Google/Apis/BigqueryV2/JobStatus#errors-instance_method
+          # `error_result` returns Google::Apis::BigqueryV2::ErrorProto if job failed.
           # Otherwise, this returns nil.
-          if _errors = _response.status.errors
+          if _response.status.error_result
             msg = "failed during waiting a #{kind} job, get_job(#{@project}, #{job_id}), errors:#{_errors.map(&:to_h)}"
             if _errors.any? {|error| error.reason == 'backendError' }
               raise BackendError, msg
@@ -347,6 +350,10 @@ def wait_load(kind, response)
             end
           end
 
+          if _errors
+            Embulk.logger.warn { "embulk-output-bigquery: #{kind} job errors... job_id:[#{job_id}] errors:#{_errors.map(&:to_h)}" }
+          end
+
           Embulk.logger.info { "embulk-output-bigquery: #{kind} job response... job_id:[#{job_id}] response.statistics:#{_response.statistics.to_h}" }
 
           _response