@@ -158,8 +158,7 @@ def file_exists(name: str) -> bool:
158158 return False
159159
160160
161- # TODO: What does gv stand for? Globus something? Global variable?
162- gv_tarfiles_pushed = 0
161+ global_variable_tarfiles_pushed = 0
163162
164163
165164# C901 'globus_transfer' is too complex (20)
@@ -172,7 +171,7 @@ def globus_transfer( # noqa: C901
172171 global transfer_data
173172 global task_id
174173 global archive_directory_listing
175- global gv_tarfiles_pushed
174+ global global_variable_tarfiles_pushed
176175
177176 logger .info (f"{ ts_utc ()} : Entered globus_transfer() for name = { name } " )
178177 logger .debug (f"{ ts_utc ()} : non_blocking = { non_blocking } " )
@@ -257,9 +256,9 @@ def globus_transfer( # noqa: C901
257256 attribs = transfer_data .__dict__
258257 for item in attribs ["data" ]["DATA" ]:
259258 if item ["DATA_TYPE" ] == "transfer_item" :
260- gv_tarfiles_pushed += 1
259+ global_variable_tarfiles_pushed += 1
261260 print (
262- f" (routine) PUSHING (#{ gv_tarfiles_pushed } ) STORED source item: { item ['source_path' ]} " ,
261+ f" (routine) PUSHING (#{ global_variable_tarfiles_pushed } ) STORED source item: { item ['source_path' ]} " ,
263262 flush = True ,
264263 )
265264
@@ -402,7 +401,7 @@ def globus_finalize(non_blocking: bool = False):
402401 global transfer_client
403402 global transfer_data
404403 global task_id
405- global gv_tarfiles_pushed
404+ global global_variable_tarfiles_pushed
406405
407406 last_task_id = None
408407
@@ -412,9 +411,9 @@ def globus_finalize(non_blocking: bool = False):
412411 attribs = transfer_data .__dict__
413412 for item in attribs ["data" ]["DATA" ]:
414413 if item ["DATA_TYPE" ] == "transfer_item" :
415- gv_tarfiles_pushed += 1
414+ global_variable_tarfiles_pushed += 1
416415 print (
417- f" (finalize) PUSHING ({ gv_tarfiles_pushed } ) source item: { item ['source_path' ]} " ,
416+ f" (finalize) PUSHING ({ global_variable_tarfiles_pushed } ) source item: { item ['source_path' ]} " ,
418417 flush = True ,
419418 )
420419
0 commit comments