@@ -388,13 +388,6 @@ def _concat_sorted(parts: list, sort_by: list) -> pd.DataFrame:
388388 "each series has enough train rows for the selection segment."
389389 )
390390
391- status .record (
392- "split_and_export" ,
393- "completed" ,
394- test_size = test_size ,
395- selection_train_size = selection_train_size ,
396- )
397-
398391 # Save test dataset to artifact
399392 test_df .to_csv (sampled_test_dataset .path , index = False )
400393
@@ -404,6 +397,13 @@ def _concat_sorted(parts: list, sort_by: list) -> pd.DataFrame:
404397 selection_train_df .to_csv (selection_path , index = False )
405398 extra_train_df .to_csv (extra_path , index = False )
406399
400+ status .record (
401+ "split_and_export" ,
402+ "completed" ,
403+ test_size = test_size ,
404+ selection_train_size = selection_train_size ,
405+ )
406+
407407 logger .info (
408408 "Timeseries loader: %s rows from s3://%s/%s; split selection=%s extra=%s test=%s" ,
409409 len (df ),
@@ -422,9 +422,6 @@ def _concat_sorted(parts: list, sort_by: list) -> pd.DataFrame:
422422 "selection_train_size" : selection_train_size ,
423423 }
424424
425- status .record ("write_outputs" , "started" )
426- status .record ("write_outputs" , "completed" )
427-
428425 # Sample rows for downstream use (ISO timestamps when supported; JSON string to avoid NaN issues)
429426 sample_tail = test_df .tail (min (5 , len (test_df )))
430427 if hasattr (sample_tail , "to_dict" ):
0 commit comments