@@ -188,7 +188,7 @@ def _get_ongoing_dict_key(self, result):
188
188
if not isinstance (result , BaseResult ):
189
189
raise ValueError (
190
190
'Any result using _get_ongoing_dict_key must subclass from '
191
- 'BaseResult. Provided result is of type: %s' % type (result )
191
+ f 'BaseResult. Provided result is of type: { type (result )} '
192
192
)
193
193
key_parts = []
194
194
for result_property in [result .transfer_type , result .src , result .dest ]:
@@ -315,7 +315,9 @@ class ResultPrinter(BaseResultHandler):
315
315
SRC_DEST_TRANSFER_LOCATION_FORMAT = '{src} to {dest}'
316
316
SRC_TRANSFER_LOCATION_FORMAT = '{src}'
317
317
318
- def __init__ (self , result_recorder , out_file = None , error_file = None , frequency = None ):
318
+ def __init__ (
319
+ self , result_recorder , out_file = None , error_file = None , frequency = None
320
+ ):
319
321
"""Prints status of ongoing transfer
320
322
321
323
:type result_recorder: ResultRecorder
@@ -353,7 +355,11 @@ def __init__(self, result_recorder, out_file=None, error_file=None, frequency=No
353
355
354
356
def __call__ (self , result ):
355
357
"""Print the progress of the ongoing transfer based on a result"""
356
- if self ._first or (self ._frequency is None ) or (time .time () - self ._now >= self ._frequency ):
358
+ if (
359
+ self ._first
360
+ or (self ._frequency is None )
361
+ or (time .time () - self ._now >= self ._frequency )
362
+ ):
357
363
self ._result_handler_map .get (type (result ), self ._print_noop )(
358
364
result = result
359
365
)
0 commit comments