Skip to content

Commit 90a83fc

Browse files
committed
Fix rebase miss. The behavior is not changed
1 parent 455de15 commit 90a83fc

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

lib/embulk/output/bigquery.rb

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -305,7 +305,7 @@ def self.auto_create(task, bigquery)
305305

306306
case task['mode']
307307
when 'delete_in_advance'
308-
bigquery.delete_partition(task['table'])
308+
bigquery.delete_table_or_partition(task['table'])
309309
bigquery.create_table_if_not_exists(task['table'])
310310
when 'replace'
311311
bigquery.create_table_if_not_exists(task['temp_table'])

test/test_transaction.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ def test_delete_in_advance
8686
task = Bigquery.configure(config, schema, processor_count)
8787
any_instance_of(BigqueryClient) do |obj|
8888
mock(obj).get_dataset(config['dataset'])
89-
mock(obj).delete_partition(config['table'])
89+
mock(obj).delete_table_or_partition(config['table'])
9090
mock(obj).create_table_if_not_exists(config['table'])
9191
end
9292
Bigquery.transaction(config, schema, processor_count, &control)
@@ -97,7 +97,7 @@ def test_delete_in_advance_with_partitioning
9797
task = Bigquery.configure(config, schema, processor_count)
9898
any_instance_of(BigqueryClient) do |obj|
9999
mock(obj).get_dataset(config['dataset'])
100-
mock(obj).delete_partition(config['table'])
100+
mock(obj).delete_table_or_partition(config['table'])
101101
mock(obj).create_table_if_not_exists(config['table'])
102102
end
103103
Bigquery.transaction(config, schema, processor_count, &control)

0 commit comments

Comments
 (0)