@@ -109,7 +109,7 @@ def test_replace
109
109
task = Bigquery . configure ( config , schema , processor_count )
110
110
any_instance_of ( BigqueryClient ) do |obj |
111
111
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
112
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
112
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
113
113
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
114
114
mock ( obj ) . copy ( config [ 'temp_table' ] , config [ 'table' ] , write_disposition : 'WRITE_TRUNCATE' )
115
115
mock ( obj ) . delete_table ( config [ 'temp_table' ] )
@@ -122,7 +122,7 @@ def test_replace_with_partitioning
122
122
task = Bigquery . configure ( config , schema , processor_count )
123
123
any_instance_of ( BigqueryClient ) do |obj |
124
124
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
125
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
125
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
126
126
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
127
127
mock ( obj ) . copy ( config [ 'temp_table' ] , config [ 'table' ] , write_disposition : 'WRITE_TRUNCATE' )
128
128
mock ( obj ) . delete_table ( config [ 'temp_table' ] )
@@ -138,7 +138,7 @@ def test_replace_backup
138
138
any_instance_of ( BigqueryClient ) do |obj |
139
139
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
140
140
mock ( obj ) . get_dataset ( config [ 'dataset_old' ] )
141
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
141
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
142
142
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
143
143
mock ( obj ) . create_table_if_not_exists ( config [ 'table_old' ] , dataset : config [ 'dataset_old' ] )
144
144
@@ -158,7 +158,7 @@ def test_replace_backup_auto_create_dataset
158
158
mock ( obj ) . create_dataset ( config [ 'dataset' ] )
159
159
mock ( obj ) . create_dataset ( config [ 'dataset_old' ] , reference : config [ 'dataset' ] )
160
160
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
161
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
161
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
162
162
mock ( obj ) . create_table_if_not_exists ( config [ 'table_old' ] , dataset : config [ 'dataset_old' ] )
163
163
164
164
mock ( obj ) . get_table_or_partition ( config [ 'table' ] )
@@ -176,7 +176,7 @@ def test_replace_backup_with_partitioning
176
176
any_instance_of ( BigqueryClient ) do |obj |
177
177
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
178
178
mock ( obj ) . get_dataset ( config [ 'dataset_old' ] )
179
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
179
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
180
180
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
181
181
mock ( obj ) . create_table_if_not_exists ( config [ 'table_old' ] , dataset : config [ 'dataset_old' ] )
182
182
@@ -196,7 +196,7 @@ def test_append
196
196
task = Bigquery . configure ( config , schema , processor_count )
197
197
any_instance_of ( BigqueryClient ) do |obj |
198
198
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
199
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
199
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
200
200
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
201
201
mock ( obj ) . copy ( config [ 'temp_table' ] , config [ 'table' ] , write_disposition : 'WRITE_APPEND' )
202
202
mock ( obj ) . delete_table ( config [ 'temp_table' ] )
@@ -209,7 +209,7 @@ def test_append_with_partitioning
209
209
task = Bigquery . configure ( config , schema , processor_count )
210
210
any_instance_of ( BigqueryClient ) do |obj |
211
211
mock ( obj ) . get_dataset ( config [ 'dataset' ] )
212
- mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] )
212
+ mock ( obj ) . create_table_if_not_exists ( config [ 'temp_table' ] , { :options => { "expiration_time" => nil } } )
213
213
mock ( obj ) . create_table_if_not_exists ( config [ 'table' ] )
214
214
mock ( obj ) . copy ( config [ 'temp_table' ] , config [ 'table' ] , write_disposition : 'WRITE_APPEND' )
215
215
mock ( obj ) . delete_table ( config [ 'temp_table' ] )
0 commit comments