@@ -342,8 +342,8 @@ def _scan_and_create_links_v2(self):
342
342
raise NotImplementedError
343
343
344
344
@classmethod
345
- def add_task (cls , project , maximum_annotations , max_inner_id , storage , link_params , link_class ):
346
- link_kwargs = asdict (link_params )
345
+ def add_task (cls , project , maximum_annotations , max_inner_id , storage , link_object , link_class ):
346
+ link_kwargs = asdict (link_object )
347
347
data = link_kwargs .pop ('task_data' )
348
348
349
349
# predictions
@@ -438,7 +438,7 @@ def _scan_and_create_links(self, link_class):
438
438
439
439
logger .debug (f'{ self } : found new key { key } ' )
440
440
try :
441
- links_params = self .get_data (key )
441
+ link_objects = self .get_data (key )
442
442
except (UnicodeDecodeError , json .decoder .JSONDecodeError ) as exc :
443
443
logger .debug (exc , exc_info = True )
444
444
raise ValueError (
@@ -448,17 +448,17 @@ def _scan_and_create_links(self, link_class):
448
448
)
449
449
450
450
if not flag_set ('fflag_feat_dia_2092_multitasks_per_storage_link' ):
451
- links_params = links_params [:1 ]
451
+ link_objects = link_objects [:1 ]
452
452
453
- for link_params in links_params :
453
+ for link_object in link_objects :
454
454
# TODO: batch this loop body with add_task -> add_tasks in a single bulk write.
455
455
# See DIA-2062 for prerequisites
456
456
task = self .add_task (
457
457
self .project ,
458
458
maximum_annotations ,
459
459
max_inner_id ,
460
460
self ,
461
- link_params ,
461
+ link_object ,
462
462
link_class = link_class ,
463
463
)
464
464
max_inner_id += 1
0 commit comments