diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/Steps/ExecuteDataProcessingStep.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/Steps/ExecuteDataProcessingStep.cs
index 388d16a..c0ddac2 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/Steps/ExecuteDataProcessingStep.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataProcessing/Steps/ExecuteDataProcessingStep.cs
@@ -1,5 +1,5 @@
+using Flowthru.Pipelines;
 using Flowthru.Services;
-using Flowthru.Services.Models;
 using LanguageExt;
 using Microsoft.Extensions.Logging;
 using Trax.Core.Step;
@@ -21,13 +21,19 @@ public override async Task<Unit> Run(DataProcessingPipelineInput input)
     {
         logger.LogInformation("Executing flowthru pipeline: {PipelineName}", input.PipelineName);
 
-        var request = new PipelineExecutionRequest
+        var options = new ExecutionOptions
         {
-            PipelineName = input.PipelineName,
-            ExportMetadata = false,
+            SliceStrategy = new PipelineSliceStrategy
+            {
+                Pipelines = new System.Collections.Generic.HashSet<string> { input.PipelineName },
+            },
         };
 
-        var result = await flowthruService.ExecutePipelineAsync(request, CancellationToken);
+        var result = await flowthruService.ExecutePipelineAsync(
+            options,
+            exportMetadata: false,
+            cancellationToken: CancellationToken
+        );
 
         if (!result.Success)
         {
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/Steps/ExecuteDataScienceStep.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/Steps/ExecuteDataScienceStep.cs
index 454425f..6771592 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/Steps/ExecuteDataScienceStep.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/DataScience/Steps/ExecuteDataScienceStep.cs
@@ -1,5 +1,5 @@
+using Flowthru.Pipelines;
 using Flowthru.Services;
-using Flowthru.Services.Models;
 using LanguageExt;
 using Microsoft.Extensions.Logging;
 using Trax.Core.Step;
@@ -21,13 +21,19 @@ public override async Task<Unit> Run(DataSciencePipelineInput input)
     {
         logger.LogInformation("Executing flowthru pipeline: {PipelineName}", input.PipelineName);
 
-        var request = new PipelineExecutionRequest
+        var options = new ExecutionOptions
         {
-            PipelineName = input.PipelineName,
-            ExportMetadata = false,
+            SliceStrategy = new PipelineSliceStrategy
+            {
+                Pipelines = new System.Collections.Generic.HashSet<string> { input.PipelineName },
+            },
         };
 
-        var result = await flowthruService.ExecutePipelineAsync(request, CancellationToken);
+        var result = await flowthruService.ExecutePipelineAsync(
+            options,
+            exportMetadata: false,
+            cancellationToken: CancellationToken
+        );
 
         if (!result.Success)
         {
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/Steps/ExecuteReportingStep.cs b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/Steps/ExecuteReportingStep.cs
index dadc546..3800e50 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/Steps/ExecuteReportingStep.cs
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trains/Reporting/Steps/ExecuteReportingStep.cs
@@ -1,5 +1,5 @@
+using Flowthru.Pipelines;
 using Flowthru.Services;
-using Flowthru.Services.Models;
 using LanguageExt;
 using Microsoft.Extensions.Logging;
 using Trax.Core.Step;
@@ -21,13 +21,19 @@ public override async Task<Unit> Run(ReportingPipelineInput input)
     {
         logger.LogInformation("Executing flowthru pipeline: {PipelineName}", input.PipelineName);
 
-        var request = new PipelineExecutionRequest
+        var options = new ExecutionOptions
         {
-            PipelineName = input.PipelineName,
-            ExportMetadata = false,
+            SliceStrategy = new PipelineSliceStrategy
+            {
+                Pipelines = new System.Collections.Generic.HashSet<string> { input.PipelineName },
+            },
         };
 
-        var result = await flowthruService.ExecutePipelineAsync(request, CancellationToken);
+        var result = await flowthruService.ExecutePipelineAsync(
+            options,
+            exportMetadata: false,
+            cancellationToken: CancellationToken
+        );
 
         if (!result.Success)
         {
diff --git a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trax.Samples.Flowthru.Spaceflights.csproj b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trax.Samples.Flowthru.Spaceflights.csproj
index 38cb01d..f9c74d6 100644
--- a/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trax.Samples.Flowthru.Spaceflights.csproj
+++ b/samples/DataPipeline/Trax.Samples.Flowthru.Spaceflights/Trax.Samples.Flowthru.Spaceflights.csproj
@@ -20,7 +20,7 @@
             Flowthru — data pipeline framework by @Spelkington
             https://github.com/chaoticgoodcomputing/flowthru
         -->
-    <PackageReference Include="Flowthru" Version="0.1.15" />
+    <PackageReference Include="Flowthru" Version="0.1.23" />
 
     <!--
             KedroSpaceflights — Catalog, Pipeline factories, Schemas