@@ -569,7 +569,10 @@ def setup(self, labeling_frontend, labeling_frontend_options) -> None:
569
569
timestamp = datetime .now (timezone .utc ).strftime ("%Y-%m-%dT%H:%M:%SZ" )
570
570
self .update (setup_complete = timestamp )
571
571
572
- def create_batch (self , name : str , data_rows : List [Union [str , "DataRow" ]], priority : "BatchPriority" = 5 ):
572
+ def create_batch (self ,
573
+ name : str ,
574
+ data_rows : List [Union [str , "DataRow" ]],
575
+ priority : "BatchPriority" = 5 ):
573
576
"""Create a new batch for a project
574
577
575
578
Args:
@@ -595,8 +598,7 @@ def create_batch(self, name: str, data_rows: List[Union[str, "DataRow"]], priori
595
598
596
599
if len (dr_ids ) > 25_000 :
597
600
raise ValueError (
598
- f"Batch exceeds max size, break into smaller batches"
599
- )
601
+ f"Batch exceeds max size, break into smaller batches" )
600
602
if not len (dr_ids ):
601
603
raise ValueError ("You need at least one data row in a batch" )
602
604
@@ -619,7 +621,8 @@ def create_batch(self, name: str, data_rows: List[Union[str, "DataRow"]], priori
619
621
}
620
622
}
621
623
622
- res = self .client .execute (query_str , params , experimental = True )["project" ][method ]
624
+ res = self .client .execute (query_str , params ,
625
+ experimental = True )["project" ][method ]
623
626
res ['size' ] = len (dr_ids )
624
627
return Entity .Batch (self .client , res )
625
628
@@ -939,7 +942,7 @@ class LabelingParameterOverride(DbObject):
939
942
940
943
LabelerPerformance = namedtuple (
941
944
"LabelerPerformance" , "user count seconds_per_label, total_time_labeling "
942
- "consensus average_benchmark_agreement last_activity_time" )
945
+ "consensus average_benchmark_agreement last_activity_time" )
943
946
LabelerPerformance .__doc__ = (
944
947
"Named tuple containing info about a labeler's performance." )
945
948
0 commit comments