@@ -121,7 +121,7 @@ def load_from_gcs(object_uris, table)
121
121
opts = { }
122
122
123
123
Embulk . logger . debug { "embulk-output-bigquery: insert_job(#{ @project } , #{ body } , #{ opts } )" }
124
- response = with_network_retry { client . insert_job ( @project , body , opts ) }
124
+ response = with_network_retry { client . insert_job ( @project , body , ** opts ) }
125
125
unless @task [ 'is_skip_job_result_check' ]
126
126
response = wait_load ( 'Load' , response )
127
127
end
@@ -222,7 +222,7 @@ def load(path, table, write_disposition: 'WRITE_APPEND')
222
222
# },
223
223
}
224
224
Embulk . logger . debug { "embulk-output-bigquery: insert_job(#{ @project } , #{ body } , #{ opts } )" }
225
- response = with_network_retry { client . insert_job ( @project , body , opts ) }
225
+ response = with_network_retry { client . insert_job ( @project , body , ** opts ) }
226
226
if @task [ 'is_skip_job_result_check' ]
227
227
response
228
228
else
@@ -278,7 +278,7 @@ def copy(source_table, destination_table, destination_dataset = nil, write_dispo
278
278
279
279
opts = { }
280
280
Embulk . logger . debug { "embulk-output-bigquery: insert_job(#{ @project } , #{ body } , #{ opts } )" }
281
- response = with_network_retry { client . insert_job ( @project , body , opts ) }
281
+ response = with_network_retry { client . insert_job ( @project , body , ** opts ) }
282
282
wait_load ( 'Copy' , response )
283
283
rescue Google ::Apis ::ServerError , Google ::Apis ::ClientError , Google ::Apis ::AuthorizationError => e
284
284
response = { status_code : e . status_code , message : e . message , error_class : e . class }
@@ -372,7 +372,7 @@ def create_dataset(dataset = nil, reference: nil)
372
372
end
373
373
opts = { }
374
374
Embulk . logger . debug { "embulk-output-bigquery: insert_dataset(#{ @project } , #{ dataset } , #{ @location_for_log } , #{ body } , #{ opts } )" }
375
- with_network_retry { client . insert_dataset ( @project , body , opts ) }
375
+ with_network_retry { client . insert_dataset ( @project , body , ** opts ) }
376
376
rescue Google ::Apis ::ServerError , Google ::Apis ::ClientError , Google ::Apis ::AuthorizationError => e
377
377
if e . status_code == 409 && /Already Exists:/ =~ e . message
378
378
# ignore 'Already Exists' error
@@ -447,7 +447,7 @@ def create_table_if_not_exists(table, dataset: nil, options: nil)
447
447
448
448
opts = { }
449
449
Embulk . logger . debug { "embulk-output-bigquery: insert_table(#{ @project } , #{ dataset } , #{ @location_for_log } , #{ body } , #{ opts } )" }
450
- with_network_retry { client . insert_table ( @project , dataset , body , opts ) }
450
+ with_network_retry { client . insert_table ( @project , dataset , body , ** opts ) }
451
451
rescue Google ::Apis ::ServerError , Google ::Apis ::ClientError , Google ::Apis ::AuthorizationError => e
452
452
if e . status_code == 409 && /Already Exists:/ =~ e . message
453
453
# ignore 'Already Exists' error
0 commit comments