@@ -506,14 +506,13 @@ def map_model_configurations_over_data_set(
506
506
def combine_time_lineage_fate_correlation (
507
507
results : List [List [SummarizeOutputs ]],
508
508
) -> List [FlyteFile ]:
509
- print (results )
509
+ output_dir = Path ("reports/time_fate_correlation" )
510
+ output_dir .mkdir (parents = True , exist_ok = True )
511
+
510
512
model_ordered_results = list (map (list , zip (* results )))
511
- print (model_ordered_results )
512
513
time_lineage_fate_correlation_plots = []
513
514
514
515
for model_results in model_ordered_results :
515
- print (model_results )
516
-
517
516
prepared_model_results = []
518
517
for model_output in model_results :
519
518
postprocessed_data_path = model_output .postprocessed_data .download ()
@@ -536,7 +535,7 @@ def combine_time_lineage_fate_correlation(
536
535
"Multilineage" ,
537
536
"All lineages" ,
538
537
][: len (prepared_model_results )],
539
- reports_path = Path ( "." ) ,
538
+ output_dir = output_dir ,
540
539
)
541
540
)
542
541
@@ -554,7 +553,7 @@ def combine_time_lineage_fate_correlation(
554
553
upload_result = upload_file_concurrently (
555
554
bucket_name = f"pyrovelocity/reports/{ execution_id } /time_fate_correlation" ,
556
555
source_filename = f"{ file } { ext } " ,
557
- destination_blob_name = f"{ file } { ext } " ,
556
+ destination_blob_name = f"{ file . name } { ext } " ,
558
557
)
559
558
attempted_upload_results .append (upload_result )
560
559
0 commit comments