make the dataset a value channel again

TARGENE · Aug 23, 2024 · 0eb0528 · 0eb0528
1 parent 6507267
commit 0eb0528
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/main.nf b/main.nf
@@ -43,8 +43,7 @@ params.TL_SAVE_EVERY = params.BATCH_SIZE
 params.ESTIMATOR_FILE = "glmnet"
 
 // Outputs Parameters
-params.ARROW_OUTPUT = "dataset.arrow"
-params.JSON_OUTPUT = "NO_JSON_OUTPUT"
+params.JSON_OUTPUT = "results.json"
 params.HDF5_OUTPUT = "results.hdf5"
 
 // Simulations

diff --git a/workflows/simulations.nf b/workflows/simulations.nf
@@ -29,7 +29,7 @@ workflow NULL_SIMULATION {
 
     }
     validated_estimands = estimation_inputs.estimands.flatten()
-    validated_dataset = estimation_inputs.dataset
+    validated_dataset = estimation_inputs.dataset.collect()
     bootstrap_grid = estimators.combine(validated_estimands).combine(sample_sizes).combine(rngs)
     simulation_results = NullSimulationEstimation(validated_dataset, bootstrap_grid)
 
@@ -57,7 +57,7 @@ workflow REALISTIC_SIMULATION {
         PCA.out.traits,
         ga_trait_table
     )
-    dataset = simulation_inputs.dataset
+    dataset = simulation_inputs.dataset.collect()
 
     // Density Estimation
     density_estimates = DensityEstimation(