File tree Expand file tree Collapse file tree 1 file changed +10
-7
lines changed
task/bq2bq/executor/bumblebee Expand file tree Collapse file tree 1 file changed +10
-7
lines changed Original file line number Diff line number Diff line change @@ -194,10 +194,10 @@ def execute(self):
194
194
195
195
if not self .dry_run :
196
196
result = self .loader .load (query )
197
-
198
- logger .info (result )
199
- logger . info ( "finished" )
200
-
197
+ logger . info ( result )
198
+ logger .info ("finished" )
199
+ else :
200
+ logger . info ( "dry-run finished" )
201
201
202
202
class TableTransformation :
203
203
"""
@@ -295,9 +295,10 @@ def execute(self):
295
295
result = None
296
296
if not self .dry_run :
297
297
result = self .loader .load (self .query )
298
-
299
- logger .info (result )
300
- logger .info ("finished" )
298
+ logger .info (result )
299
+ logger .info ("finished" )
300
+ else :
301
+ logger .info ("dry-run finished" )
301
302
302
303
async def async_execute (self ):
303
304
self .execute ()
@@ -355,6 +356,8 @@ def transform(self):
355
356
if not self .dry_run :
356
357
result = self .loader .load (query )
357
358
logger .info ("finished {}" .format (result .total_rows ))
359
+ else :
360
+ logger .info ("dry-run finished" )
358
361
359
362
360
363
class MultiPartitionTransformation :
You can’t perform that action at this time.
0 commit comments