@@ -1984,9 +1984,6 @@ def publish_batch_data(
19841984 "Make sure to fix all of the issues listed above before the upload." ,
19851985 ) from None
19861986
1987- # Check if batch of data contains ground truths
1988- contains_ground_truths = self ._contains_ground_truths (batch_config = batch_data )
1989-
19901987 # Load dataset config and augment with defaults
19911988 batch_data = DatasetSchema ().load (
19921989 {"task_type" : task_type .value , ** batch_config }
@@ -2009,7 +2006,7 @@ def publish_batch_data(
20092006 payload = {
20102007 "earliestTimestamp" : int (earliest_timestamp ),
20112008 "latestTimestamp" : int (latest_timestamp ),
2012- "performGroundTruthMerge" : not contains_ground_truths ,
2009+ "performGroundTruthMerge" : False ,
20132010 ** batch_data ,
20142011 }
20152012
@@ -2038,14 +2035,6 @@ def _add_default_column(
20382035 df [inference_id_column_name ] = [str (uuid .uuid1 ()) for _ in range (len (df ))]
20392036 return config , df
20402037
2041- def _contains_ground_truths (self , batch_config : Dict [str , any ]) -> bool :
2042- """Checks if the batch of data contains ground truths."""
2043- return (
2044- batch_config .get ("groundTruthColumnName" ) is not None
2045- or batch_config .get ("labelColumnName" ) is not None
2046- or batch_config .get ("targetColumnName" ) is not None
2047- )
2048-
20492038 def publish_ground_truths (
20502039 self ,
20512040 inference_pipeline_id : str ,
0 commit comments