Skip to content

Commit 0669a2a

Browse files
authored
Merge pull request #19 from trocco-io/ignroe-patch-table-error
ignore patch table error
2 parents cdc98f2 + 4bc56a3 commit 0669a2a

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

lib/embulk/output/bigquery.rb

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,6 @@ def self.transaction(config, schema, task_count, &control)
330330
@converters = ValueConverterFactory.create_converters(task, schema)
331331

332332
self.auto_create(@task, @bigquery)
333-
bigquery.patch_table
334333

335334
begin
336335
paths = []
@@ -400,6 +399,13 @@ def self.transaction(config, schema, task_count, &control)
400399
end
401400
end
402401

402+
begin
403+
bigquery.patch_table
404+
rescue => e
405+
Embulk.logger.warn("patch_table is failed")
406+
Embulk.logger.warn("#{e.class} : #{e.message}")
407+
end
408+
403409
ensure
404410
begin
405411
if task['temp_table'] # append or replace or replace_backup

0 commit comments

Comments
 (0)