diff --git a/_pkgdown.yml b/_pkgdown.yml index 5f52493..694af7b 100644 --- a/_pkgdown.yml +++ b/_pkgdown.yml @@ -35,7 +35,7 @@ reference: navbar: structure: left: [home, reference, articles, myPackages] - right: [search, github, stackoverflow, bluesky, blog] + right: [github, stackoverflow, bluesky, blog] components: home: icon: fa-home fa-lg diff --git a/docs/404.html b/docs/404.html index 143c861..1411878 100644 --- a/docs/404.html +++ b/docs/404.html @@ -64,9 +64,6 @@
pip$run()
-# INFO [2024-12-01 21:41:31.888] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:31.916] Step 1/6 data
-# INFO [2024-12-01 21:41:31.925] Step 2/6 data_prep
-# INFO [2024-12-01 21:41:31.948] Step 3/6 data_summary
-# INFO [2024-12-01 21:41:31.950] Step 4/6 model_fit
-# INFO [2024-12-01 21:41:31.954] Step 5/6 model_summary
-# INFO [2024-12-01 21:41:31.956] Step 6/6 model_plot
-# INFO [2024-12-01 21:41:31.968] Finished execution of steps.
-# INFO [2024-12-01 21:41:31.968] Done.
+# INFO [2024-12-01 21:46:27.511] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:27.539] Step 1/6 data
+# INFO [2024-12-01 21:46:27.548] Step 2/6 data_prep
+# INFO [2024-12-01 21:46:27.572] Step 3/6 data_summary
+# INFO [2024-12-01 21:46:27.573] Step 4/6 model_fit
+# INFO [2024-12-01 21:46:27.577] Step 5/6 model_summary
+# INFO [2024-12-01 21:46:27.580] Step 6/6 model_plot
+# INFO [2024-12-01 21:46:27.591] Finished execution of steps.
+# INFO [2024-12-01 21:46:27.591] Done.
out <- pip$collect_out()
@@ -310,15 +307,15 @@ Grouping output steps
pip$run()
-# INFO [2024-12-01 21:41:32.198] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:32.199] Step 1/6 data
-# INFO [2024-12-01 21:41:32.202] Step 2/6 data_prep
-# INFO [2024-12-01 21:41:32.205] Step 3/6 used_data
-# INFO [2024-12-01 21:41:32.206] Step 4/6 model_fit
-# INFO [2024-12-01 21:41:32.229] Step 5/6 model_summary
-# INFO [2024-12-01 21:41:32.231] Step 6/6 model_plot
-# INFO [2024-12-01 21:41:32.236] Finished execution of steps.
-# INFO [2024-12-01 21:41:32.237] Done.
+# INFO [2024-12-01 21:46:27.822] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:27.823] Step 1/6 data
+# INFO [2024-12-01 21:46:27.826] Step 2/6 data_prep
+# INFO [2024-12-01 21:46:27.829] Step 3/6 used_data
+# INFO [2024-12-01 21:46:27.830] Step 4/6 model_fit
+# INFO [2024-12-01 21:46:27.853] Step 5/6 model_summary
+# INFO [2024-12-01 21:46:27.855] Step 6/6 model_plot
+# INFO [2024-12-01 21:46:27.860] Finished execution of steps.
+# INFO [2024-12-01 21:46:27.861] Done.
out <- pip$collect_out()
diff --git a/docs/articles/combine-pipelines.html b/docs/articles/combine-pipelines.html
index 8c7b9dc..9a74c1a 100644
--- a/docs/articles/combine-pipelines.html
+++ b/docs/articles/combine-pipelines.html
@@ -68,9 +68,6 @@
-
@@ -291,8 +288,8 @@ Relative indexing# [[1]]
# function (data = ~-1)
# data
-# <bytecode: 0x000001c01370b3f8>
-# <environment: 0x000001c00f2b05a8>
+# <bytecode: 0x0000015b1cf930e8>
+# <environment: 0x0000015b18bae928>
pip$get_out("plot")
# Warning: Removed 37 rows containing missing values or values outside the scale range
@@ -323,15 +320,15 @@ Run combined pipeline
pip$run()
-# INFO [2024-12-01 21:41:37.360] Start run of 'preprocessing.modeling' pipeline:
-# INFO [2024-12-01 21:41:37.361] Step 1/6 data - skip 'done' step
-# INFO [2024-12-01 21:41:37.362] Step 2/6 data_prep - skip 'done' step
-# INFO [2024-12-01 21:41:37.362] Step 3/6 standardize - skip 'done' step
-# INFO [2024-12-01 21:41:37.363] Step 4/6 data.modeling - skip 'done' step
-# INFO [2024-12-01 21:41:37.364] Step 5/6 fit
-# INFO [2024-12-01 21:41:37.368] Step 6/6 plot
-# INFO [2024-12-01 21:41:37.385] Finished execution of steps.
-# INFO [2024-12-01 21:41:37.386] Done.
pip$get_out("plot")
diff --git a/docs/articles/get-started.html b/docs/articles/get-started.html
index a713267..c70b34b 100644
--- a/docs/articles/get-started.html
+++ b/docs/articles/get-started.html
@@ -68,9 +68,6 @@
-
@@ -232,13 +229,13 @@ Run the pipeline and inspect th
the pipeline, which will produce the following output:
pip$run()
-# INFO [2024-12-01 21:41:41.560] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:41.586] Step 1/4 data
-# INFO [2024-12-01 21:41:41.597] Step 2/4 data_prep
-# INFO [2024-12-01 21:41:41.620] Step 3/4 model_fit
-# INFO [2024-12-01 21:41:41.623] Step 4/4 model_plot
-# INFO [2024-12-01 21:41:41.635] Finished execution of steps.
-# INFO [2024-12-01 21:41:41.636] Done.
+# INFO [2024-12-01 21:46:37.075] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:37.101] Step 1/4 data
+# INFO [2024-12-01 21:46:37.112] Step 2/4 data_prep
+# INFO [2024-12-01 21:46:37.134] Step 3/4 model_fit
+# INFO [2024-12-01 21:46:37.138] Step 4/4 model_plot
+# INFO [2024-12-01 21:46:37.149] Finished execution of steps.
+# INFO [2024-12-01 21:46:37.150] Done.
Let’s inspect the pipeline again.
The outdated steps were re-run as expected and the output was updated accordingly.
@@ -348,13 +345,13 @@Change parameters of the pipeline# 4: model_plot model_fit,data_prep <gg[11]> FALSE model_plot Outdated
pip$run()$get_out("model_plot")
-# INFO [2024-12-01 21:41:42.919] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:42.920] Step 1/4 data - skip 'done' step
-# INFO [2024-12-01 21:41:42.921] Step 2/4 data_prep - skip 'done' step
-# INFO [2024-12-01 21:41:42.922] Step 3/4 model_fit - skip 'done' step
-# INFO [2024-12-01 21:41:42.923] Step 4/4 model_plot
-# INFO [2024-12-01 21:41:42.931] Finished execution of steps.
-# INFO [2024-12-01 21:41:42.931] Done.
If instead we were to change the input data, since all steps depend on it, we expect all steps to be rerun.
@@ -369,13 +366,13 @@
pip$run()$get_out("model_plot")
-# INFO [2024-12-01 21:41:43.202] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:43.203] Step 1/4 data
-# INFO [2024-12-01 21:41:43.206] Step 2/4 data_prep
-# INFO [2024-12-01 21:41:43.211] Step 3/4 model_fit
-# INFO [2024-12-01 21:41:43.214] Step 4/4 model_plot
-# INFO [2024-12-01 21:41:43.219] Finished execution of steps.
-# INFO [2024-12-01 21:41:43.220] Done.
Next, let’s see how to modify the pipeline.
diff --git a/docs/articles/index.html b/docs/articles/index.html index cc812aa..f15ca9d 100644 --- a/docs/articles/index.html +++ b/docs/articles/index.html @@ -37,9 +37,7 @@
pip$set_params(list(xVar = "Solar.R", yVar = "Wind"))
pip$run()
-# INFO [2024-12-01 21:41:47.485] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:47.486] Step 1/5 data - skip 'done' step
-# INFO [2024-12-01 21:41:47.487] Step 2/5 data_prep - skip 'done' step
-# INFO [2024-12-01 21:41:47.488] Step 3/5 standardize
-# INFO [2024-12-01 21:41:47.490] Step 4/5 model_fit
-# INFO [2024-12-01 21:41:47.493] Step 5/5 model_plot
-# INFO [2024-12-01 21:41:47.498] Finished execution of steps.
-# INFO [2024-12-01 21:41:47.498] Done.
+# INFO [2024-12-01 21:46:43.011] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:43.012] Step 1/5 data - skip 'done' step
+# INFO [2024-12-01 21:46:43.013] Step 2/5 data_prep - skip 'done' step
+# INFO [2024-12-01 21:46:43.014] Step 3/5 standardize
+# INFO [2024-12-01 21:46:43.016] Step 4/5 model_fit
+# INFO [2024-12-01 21:46:43.019] Step 5/5 model_plot
+# INFO [2024-12-01 21:46:43.024] Finished execution of steps.
+# INFO [2024-12-01 21:46:43.025] Done.
pip$get_out("model_fit") |> coefficients()
# (Intercept) Solar.R
diff --git a/docs/articles/self-modify-pipeline.html b/docs/articles/self-modify-pipeline.html
index 03d5e2d..d6b9dd3 100644
--- a/docs/articles/self-modify-pipeline.html
+++ b/docs/articles/self-modify-pipeline.html
@@ -68,9 +68,6 @@
-
@@ -162,13 +159,13 @@ Changing pipeline parameters at
pip$set_data(airquality)
pip$set_params(list(xVar = "Ozone", yVar = "Temp"))
pip$run()$collect_out()
-# INFO [2024-12-01 21:41:51.403] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:51.430] Step 1/4 data
-# INFO [2024-12-01 21:41:51.444] Step 2/4 fit
-# INFO [2024-12-01 21:41:51.462] Step 3/4 residual_shapiro_p_value
-# INFO [2024-12-01 21:41:51.464] Step 4/4 plot
-# INFO [2024-12-01 21:41:51.481] Finished execution of steps.
-# INFO [2024-12-01 21:41:51.482] Done.
+# INFO [2024-12-01 21:46:46.851] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:46.880] Step 1/4 data
+# INFO [2024-12-01 21:46:46.895] Step 2/4 fit
+# INFO [2024-12-01 21:46:46.912] Step 3/4 residual_shapiro_p_value
+# INFO [2024-12-01 21:46:46.914] Step 4/4 plot
+# INFO [2024-12-01 21:46:46.930] Finished execution of steps.
+# INFO [2024-12-01 21:46:46.931] Done.
# $residual_shapiro_p_value
# [1] 0.00022598
#
@@ -187,13 +184,13 @@ Changing pipeline parameters at
pip$set_params(list(pointColor = "red"))
pip$run()$collect_out()
}
-# INFO [2024-12-01 21:41:51.876] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:51.877] Step 1/4 data - skip 'done' step
-# INFO [2024-12-01 21:41:51.878] Step 2/4 fit - skip 'done' step
-# INFO [2024-12-01 21:41:51.879] Step 3/4 residual_shapiro_p_value - skip 'done' step
-# INFO [2024-12-01 21:41:51.880] Step 4/4 plot
-# INFO [2024-12-01 21:41:51.893] Finished execution of steps.
-# INFO [2024-12-01 21:41:51.894] Done.
+# INFO [2024-12-01 21:46:47.325] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:47.326] Step 1/4 data - skip 'done' step
+# INFO [2024-12-01 21:46:47.327] Step 2/4 fit - skip 'done' step
+# INFO [2024-12-01 21:46:47.328] Step 3/4 residual_shapiro_p_value - skip 'done' step
+# INFO [2024-12-01 21:46:47.329] Step 4/4 plot
+# INFO [2024-12-01 21:46:47.342] Finished execution of steps.
+# INFO [2024-12-01 21:46:47.342] Done.
# $residual_shapiro_p_value
# [1] 0.00022598
#
@@ -231,13 +228,13 @@ Changing pipeline parameters at
pip$set_data(airquality)
pip$set_params(list(xVar = "Ozone", yVar = "Temp", .self = pip))
pip$run()$collect_out()
-# INFO [2024-12-01 21:41:52.189] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.190] Step 1/4 data
-# INFO [2024-12-01 21:41:52.192] Step 2/4 fit
-# INFO [2024-12-01 21:41:52.196] Step 3/4 residual_shapiro_p_value
-# INFO [2024-12-01 21:41:52.200] Step 4/4 plot
-# INFO [2024-12-01 21:41:52.207] Finished execution of steps.
-# INFO [2024-12-01 21:41:52.207] Done.
+# INFO [2024-12-01 21:46:47.638] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:47.640] Step 1/4 data
+# INFO [2024-12-01 21:46:47.642] Step 2/4 fit
+# INFO [2024-12-01 21:46:47.646] Step 3/4 residual_shapiro_p_value
+# INFO [2024-12-01 21:46:47.650] Step 4/4 plot
+# INFO [2024-12-01 21:46:47.657] Finished execution of steps.
+# INFO [2024-12-01 21:46:47.658] Done.
# $residual_shapiro_p_value
# [1] 0.00022598
#
@@ -281,13 +278,13 @@ Changing the pipeline struct
respectively.
pip$set_data(1)$run()
-# INFO [2024-12-01 21:41:52.449] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.450] Step 1/4 data
-# INFO [2024-12-01 21:41:52.452] Step 2/4 f1
-# INFO [2024-12-01 21:41:52.454] Step 3/4 f2
-# INFO [2024-12-01 21:41:52.456] Step 4/4 f3
-# INFO [2024-12-01 21:41:52.457] Finished execution of steps.
-# INFO [2024-12-01 21:41:52.458] Done.
+# INFO [2024-12-01 21:46:47.901] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:47.902] Step 1/4 data
+# INFO [2024-12-01 21:46:47.904] Step 2/4 f1
+# INFO [2024-12-01 21:46:47.907] Step 3/4 f2
+# INFO [2024-12-01 21:46:47.908] Step 4/4 f3
+# INFO [2024-12-01 21:46:47.910] Finished execution of steps.
+# INFO [2024-12-01 21:46:47.910] Done.
pip
# step depends out keepOut group state
# <char> <list> <list> <lgcl> <char> <char>
@@ -340,13 +337,13 @@ Modify a step
pip$set_params(list(.self = pip))
pip$set_data(1)$run()
-# INFO [2024-12-01 21:41:52.575] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.576] Step 1/4 data
-# INFO [2024-12-01 21:41:52.578] Step 2/4 f1
-# INFO [2024-12-01 21:41:52.580] Step 3/4 f2
-# INFO [2024-12-01 21:41:52.582] Step 4/4 f3
-# INFO [2024-12-01 21:41:52.584] Finished execution of steps.
-# INFO [2024-12-01 21:41:52.584] Done.
+# INFO [2024-12-01 21:46:48.028] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:48.029] Step 1/4 data
+# INFO [2024-12-01 21:46:48.031] Step 2/4 f1
+# INFO [2024-12-01 21:46:48.034] Step 3/4 f2
+# INFO [2024-12-01 21:46:48.035] Step 4/4 f3
+# INFO [2024-12-01 21:46:48.037] Finished execution of steps.
+# INFO [2024-12-01 21:46:48.037] Done.
pip
# step depends out keepOut group state
# <char> <list> <list> <lgcl> <char> <char>
@@ -357,13 +354,13 @@ Modify a step
pip$set_data(10)$run()
-# INFO [2024-12-01 21:41:52.643] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.644] Step 1/4 data
-# INFO [2024-12-01 21:41:52.646] Step 2/4 f1
-# INFO [2024-12-01 21:41:52.649] Step 3/4 f2
-# INFO [2024-12-01 21:41:52.654] Step 4/4 f3
-# INFO [2024-12-01 21:41:52.656] Finished execution of steps.
-# INFO [2024-12-01 21:41:52.656] Done.
+# INFO [2024-12-01 21:46:48.096] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:48.097] Step 1/4 data
+# INFO [2024-12-01 21:46:48.099] Step 2/4 f1
+# INFO [2024-12-01 21:46:48.102] Step 3/4 f2
+# INFO [2024-12-01 21:46:48.108] Step 4/4 f3
+# INFO [2024-12-01 21:46:48.109] Finished execution of steps.
+# INFO [2024-12-01 21:46:48.110] Done.
pip
# step depends out keepOut group state
# <char> <list> <list> <lgcl> <char> <char>
@@ -452,19 +449,19 @@ Insert and remove steps
pip$set_params(list(.self = pip))
pip$set_data(10)$run()
-# INFO [2024-12-01 21:41:52.829] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.830] Step 1/4 data
-# INFO [2024-12-01 21:41:52.832] Step 2/4 f1
-# INFO [2024-12-01 21:41:52.834] Step 3/4 f2
-# INFO [2024-12-01 21:41:52.848] Abort pipeline execution and restart on new.
-# INFO [2024-12-01 21:41:52.848] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:52.849] Step 1/5 data - skip 'done' step
-# INFO [2024-12-01 21:41:52.850] Step 2/5 f1 - skip 'done' step
-# INFO [2024-12-01 21:41:52.851] Step 3/5 f2a
-# INFO [2024-12-01 21:41:52.856] Step 4/5 f2b
-# INFO [2024-12-01 21:41:52.858] Step 5/5 f3
-# INFO [2024-12-01 21:41:52.859] Finished execution of steps.
-# INFO [2024-12-01 21:41:52.860] Done.
+# INFO [2024-12-01 21:46:48.282] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:48.283] Step 1/4 data
+# INFO [2024-12-01 21:46:48.285] Step 2/4 f1
+# INFO [2024-12-01 21:46:48.287] Step 3/4 f2
+# INFO [2024-12-01 21:46:48.300] Abort pipeline execution and restart on new.
+# INFO [2024-12-01 21:46:48.301] Start run of 'my-pipeline' pipeline:
+# INFO [2024-12-01 21:46:48.302] Step 1/5 data - skip 'done' step
+# INFO [2024-12-01 21:46:48.302] Step 2/5 f1 - skip 'done' step
+# INFO [2024-12-01 21:46:48.303] Step 3/5 f2a
+# INFO [2024-12-01 21:46:48.308] Step 4/5 f2b
+# INFO [2024-12-01 21:46:48.310] Step 5/5 f3
+# INFO [2024-12-01 21:46:48.312] Finished execution of steps.
+# INFO [2024-12-01 21:46:48.312] Done.
The log output shows the abort and re-run of the pipeline. Let’s see the final structure and step outputs.
diff --git a/docs/articles/split-and-combine.html b/docs/articles/split-and-combine.html index 855d968..8978c94 100644 --- a/docs/articles/split-and-combine.html +++ b/docs/articles/split-and-combine.html @@ -68,9 +68,6 @@
pip$collect_out()
# $coefs
@@ -195,24 +192,24 @@ Split data set}
results <- lapply(split(iris, iris$Species), FUN = run_pipeline)
-# INFO [2024-12-01 21:41:56.192] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:56.193] Step 1/3 data
-# INFO [2024-12-01 21:41:56.195] Step 2/3 fit
-# INFO [2024-12-01 21:41:56.199] Step 3/3 coefs
-# INFO [2024-12-01 21:41:56.203] Finished execution of steps.
-# INFO [2024-12-01 21:41:56.204] Done.
-# INFO [2024-12-01 21:41:56.222] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:56.223] Step 1/3 data
-# INFO [2024-12-01 21:41:56.225] Step 2/3 fit
-# INFO [2024-12-01 21:41:56.227] Step 3/3 coefs
-# INFO [2024-12-01 21:41:56.228] Finished execution of steps.
-# INFO [2024-12-01 21:41:56.229] Done.
-# INFO [2024-12-01 21:41:56.232] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:56.233] Step 1/3 data
-# INFO [2024-12-01 21:41:56.235] Step 2/3 fit
-# INFO [2024-12-01 21:41:56.238] Step 3/3 coefs
-# INFO [2024-12-01 21:41:56.239] Finished execution of steps.
-# INFO [2024-12-01 21:41:56.239] Done.
pip$collect_out()
# $setosa
@@ -415,19 +412,19 @@ Combine output
pip$set_params(list(xVar = "Sepal.Length", yVar = "Sepal.Width"))
pip$run()
-# INFO [2024-12-01 21:41:57.260] Start run of 'my-pipeline' pipeline:
-# INFO [2024-12-01 21:41:57.263] Step 1/10 data.setosa
-# INFO [2024-12-01 21:41:57.265] Step 2/10 fit.setosa
-# INFO [2024-12-01 21:41:57.268] Step 3/10 coefs.setosa
-# INFO [2024-12-01 21:41:57.270] Step 4/10 data.versicolor
-# INFO [2024-12-01 21:41:57.272] Step 5/10 fit.versicolor
-# INFO [2024-12-01 21:41:57.275] Step 6/10 coefs.versicolor
-# INFO [2024-12-01 21:41:57.277] Step 7/10 data.virginica
-# INFO [2024-12-01 21:41:57.279] Step 8/10 fit.virginica
-# INFO [2024-12-01 21:41:57.282] Step 9/10 coefs.virginica
-# INFO [2024-12-01 21:41:57.284] Step 10/10 combine_coefs
-# INFO [2024-12-01 21:41:57.286] Finished execution of steps.
-# INFO [2024-12-01 21:41:57.286] Done.
pip$collect_out()
# $combine_coefs
diff --git a/docs/authors.html b/docs/authors.html
index 530bbb1..2046911 100644
--- a/docs/authors.html
+++ b/docs/authors.html
@@ -37,9 +37,7 @@
- GroupSeq
- pipeflow
-
diff --git a/docs/index.html b/docs/index.html
index c8f6893..bad2b1d 100644
--- a/docs/index.html
+++ b/docs/index.html
@@ -66,9 +66,6 @@
-
diff --git a/docs/pkgdown.yml b/docs/pkgdown.yml
index 2ad7bfb..d3d8a4f 100644
--- a/docs/pkgdown.yml
+++ b/docs/pkgdown.yml
@@ -8,7 +8,7 @@ articles:
modify-pipeline: modify-pipeline.html
self-modify-pipeline: self-modify-pipeline.html
split-and-combine: split-and-combine.html
-last_built: 2024-12-01T20:41Z
+last_built: 2024-12-01T20:46Z
urls:
reference: https://github.com/rpahl/pipeflow/reference
article: https://github.com/rpahl/pipeflow/articles
diff --git a/docs/reference/Pipeline.html b/docs/reference/Pipeline.html
index 0d6a960..48b9b1e 100644
--- a/docs/reference/Pipeline.html
+++ b/docs/reference/Pipeline.html
@@ -53,9 +53,7 @@
- GroupSeq
- pipeflow
-
@@ -1802,11 +1800,11 @@ Examplesp <- Pipeline$new("myPipe", data = c(1, 2, NA, 3, 4))
p$add("calc_mean", mean, params = list(x = ~data, na.rm = TRUE))
p$run()$get_out("calc_mean")
-#> INFO [2024-12-01 21:41:21.908] Start run of 'myPipe' pipeline:
-#> INFO [2024-12-01 21:41:21.933] Step 1/2 data
-#> INFO [2024-12-01 21:41:21.942] Step 2/2 calc_mean
-#> INFO [2024-12-01 21:41:21.961] Finished execution of steps.
-#> INFO [2024-12-01 21:41:21.962] Done.
+#> INFO [2024-12-01 21:46:17.666] Start run of 'myPipe' pipeline:
+#> INFO [2024-12-01 21:46:17.694] Step 1/2 data
+#> INFO [2024-12-01 21:46:17.703] Step 2/2 calc_mean
+#> INFO [2024-12-01 21:46:17.723] Finished execution of steps.
+#> INFO [2024-12-01 21:46:17.724] Done.
#> [1] 2.5
p <- Pipeline$new("myPipe", data = 1:10)
@@ -1823,21 +1821,21 @@ Examples#> 2: s1 <function[1]> function <list[1]> data [NULL] FALSE s1
#> description time state
#> <char> <POSc> <char>
-#> 1: 2024-12-01 21:41:21 New
-#> 2: multiply by 2 2024-12-01 21:41:21 New
+#> 1: 2024-12-01 21:46:17 New
+#> 2: multiply by 2 2024-12-01 21:46:17 New
p <- Pipeline$new("myPipe", data = data.frame(x = 1:5, y = 1:5))
p$add("prep_x", \(data = ~data) data$x, group = "prep")
p$add("prep_y", \(data = ~data) (data$y)^2, group = "prep")
p$add("sum", \(x = ~prep_x, y = ~prep_y) x + y)
p$run()$collect_out(all = TRUE)
-#> INFO [2024-12-01 21:41:21.975] Start run of 'myPipe' pipeline:
-#> INFO [2024-12-01 21:41:21.976] Step 1/4 data
-#> INFO [2024-12-01 21:41:21.979] Step 2/4 prep_x
-#> INFO [2024-12-01 21:41:21.981] Step 3/4 prep_y
-#> INFO [2024-12-01 21:41:21.983] Step 4/4 sum
-#> INFO [2024-12-01 21:41:21.984] Finished execution of steps.
-#> INFO [2024-12-01 21:41:21.985] Done.
+#> INFO [2024-12-01 21:46:17.739] Start run of 'myPipe' pipeline:
+#> INFO [2024-12-01 21:46:17.740] Step 1/4 data
+#> INFO [2024-12-01 21:46:17.742] Step 2/4 prep_x
+#> INFO [2024-12-01 21:46:17.744] Step 3/4 prep_y
+#> INFO [2024-12-01 21:46:17.746] Step 4/4 sum
+#> INFO [2024-12-01 21:46:17.747] Finished execution of steps.
+#> INFO [2024-12-01 21:46:17.748] Done.
#> $data
#> x y
#> 1 1 1
@@ -1917,12 +1915,12 @@ Examplesp$add("step1", \(x = ~data) x + 2)
p$add("step2", \(x = ~step1) x + 2, keepOut = TRUE)
p$run()
-#> INFO [2024-12-01 21:41:22.118] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.119] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.121] Step 2/3 step1
-#> INFO [2024-12-01 21:41:22.123] Step 3/3 step2
-#> INFO [2024-12-01 21:41:22.124] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.125] Done.
+#> INFO [2024-12-01 21:46:17.887] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:17.892] Step 1/3 data
+#> INFO [2024-12-01 21:46:17.894] Step 2/3 step1
+#> INFO [2024-12-01 21:46:17.896] Step 3/3 step2
+#> INFO [2024-12-01 21:46:17.897] Finished execution of steps.
+#> INFO [2024-12-01 21:46:17.898] Done.
p$collect_out()
#> $step2
#> [1] 5 6
@@ -1947,14 +1945,14 @@ Examples#> 4: step3 data [NULL] FALSE mult New
#> 5: step4 data [NULL] FALSE mult New
p$run()
-#> INFO [2024-12-01 21:41:22.154] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.155] Step 1/5 data
-#> INFO [2024-12-01 21:41:22.157] Step 2/5 step1
-#> INFO [2024-12-01 21:41:22.159] Step 3/5 step2
-#> INFO [2024-12-01 21:41:22.160] Step 4/5 step3
-#> INFO [2024-12-01 21:41:22.162] Step 5/5 step4
-#> INFO [2024-12-01 21:41:22.163] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.164] Done.
+#> INFO [2024-12-01 21:46:17.924] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:17.925] Step 1/5 data
+#> INFO [2024-12-01 21:46:17.928] Step 2/5 step1
+#> INFO [2024-12-01 21:46:17.930] Step 3/5 step2
+#> INFO [2024-12-01 21:46:17.931] Step 4/5 step3
+#> INFO [2024-12-01 21:46:17.933] Step 5/5 step4
+#> INFO [2024-12-01 21:46:17.934] Finished execution of steps.
+#> INFO [2024-12-01 21:46:17.935] Done.
p$collect_out(all = TRUE) |> str()
#> List of 3
#> $ data: int [1:2] 1 2
@@ -2110,12 +2108,12 @@ Examplesp$add("add1", \(x = ~data) x + 1)
p$add("add2", \(x = ~data, y = ~add1) x + y)
p$run()
-#> INFO [2024-12-01 21:41:22.273] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.274] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.276] Step 2/3 add1
-#> INFO [2024-12-01 21:41:22.278] Step 3/3 add2
-#> INFO [2024-12-01 21:41:22.279] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.280] Done.
+#> INFO [2024-12-01 21:46:18.047] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.048] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.050] Step 2/3 add1
+#> INFO [2024-12-01 21:46:18.052] Step 3/3 add2
+#> INFO [2024-12-01 21:46:18.053] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.053] Done.
p$get_out("add1")
#> [1] 2 3
p$get_out("add2")
@@ -2242,12 +2240,12 @@ Examplesp$add("add1", \(data = ~data, x = 1) x + data)
p$add("add2", \(x = 1, y = 2, z = ~add1) x + y + z)
p$run()
-#> INFO [2024-12-01 21:41:22.322] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.323] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.325] Step 2/3 add1
-#> INFO [2024-12-01 21:41:22.326] Step 3/3 add2
-#> INFO [2024-12-01 21:41:22.328] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.328] Done.
+#> INFO [2024-12-01 21:46:18.092] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.093] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.095] Step 2/3 add1
+#> INFO [2024-12-01 21:46:18.097] Step 3/3 add2
+#> INFO [2024-12-01 21:46:18.098] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.099] Done.
add1 <- p$get_step("add1")
print(add1)
#> step fun funcName params depends out keepOut group
@@ -2255,12 +2253,12 @@ Examples#> 1: add1 <function[1]> function <list[2]> data 2,3 FALSE add1
#> description time state
#> <char> <POSc> <char>
-#> 1: 2024-12-01 21:41:22 Done
+#> 1: 2024-12-01 21:46:18 Done
add1[["params"]]
#> [[1]]
#> [[1]]$data
#> ~data
-#> <environment: 0x000002328176fc38>
+#> <environment: 0x00000296abb38438>
#>
#> [[1]]$x
#> [1] 1
@@ -2357,12 +2355,12 @@ Examplesp$add("add1", \(x = 1, data = ~data) x + data)
p$add("add2", \(x = 1, data = ~data) x + data)
p$run()
-#> INFO [2024-12-01 21:41:22.370] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.371] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.373] Step 2/3 add1
-#> INFO [2024-12-01 21:41:22.375] Step 3/3 add2
-#> INFO [2024-12-01 21:41:22.376] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.376] Done.
+#> INFO [2024-12-01 21:46:18.141] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.142] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.144] Step 2/3 add1
+#> INFO [2024-12-01 21:46:18.146] Step 3/3 add2
+#> INFO [2024-12-01 21:46:18.147] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.147] Done.
p$get_out("add1")
#> [1] 2
p$get_out("add2")
@@ -2373,12 +2371,12 @@ Examplesp$set_params(list(x = 3))
#> skipping setting parameters x at locked step 'add1'
p$run()
-#> INFO [2024-12-01 21:41:22.396] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.397] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.399] Step 2/3 add1 - skip 'locked' step
-#> INFO [2024-12-01 21:41:22.400] Step 3/3 add2
-#> INFO [2024-12-01 21:41:22.401] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.402] Done.
+#> INFO [2024-12-01 21:46:18.168] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.169] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.171] Step 2/3 add1 - skip 'locked' step
+#> INFO [2024-12-01 21:46:18.172] Step 3/3 add2
+#> INFO [2024-12-01 21:46:18.173] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.173] Done.
p$get_out("add1")
#> [1] 2
p$get_out("add2")
@@ -2508,25 +2506,25 @@ Examplesp$add("add2", \(x = ~data, y = 2) x + y)
p$add("mult", \(x = 1, y = 2) x * y, keepOut = TRUE)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:22.462] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.463] Step 1/4 data
-#> INFO [2024-12-01 21:41:22.465] Step 2/4 add1
-#> INFO [2024-12-01 21:41:22.466] Step 3/4 add2
-#> INFO [2024-12-01 21:41:22.468] Step 4/4 mult
-#> INFO [2024-12-01 21:41:22.469] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.469] Done.
+#> INFO [2024-12-01 21:46:18.233] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.234] Step 1/4 data
+#> INFO [2024-12-01 21:46:18.236] Step 2/4 add1
+#> INFO [2024-12-01 21:46:18.237] Step 3/4 add2
+#> INFO [2024-12-01 21:46:18.239] Step 4/4 mult
+#> INFO [2024-12-01 21:46:18.240] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.240] Done.
#> $mult
#> [1] 2
#>
p$replace_step("mult", \(x = ~add1, y = ~add2) x * y, keepOut = TRUE)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:22.472] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.473] Step 1/4 data - skip 'done' step
-#> INFO [2024-12-01 21:41:22.474] Step 2/4 add1 - skip 'done' step
-#> INFO [2024-12-01 21:41:22.475] Step 3/4 add2 - skip 'done' step
-#> INFO [2024-12-01 21:41:22.476] Step 4/4 mult
-#> INFO [2024-12-01 21:41:22.477] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.477] Done.
+#> INFO [2024-12-01 21:46:18.243] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.244] Step 1/4 data - skip 'done' step
+#> INFO [2024-12-01 21:46:18.245] Step 2/4 add1 - skip 'done' step
+#> INFO [2024-12-01 21:46:18.246] Step 3/4 add2 - skip 'done' step
+#> INFO [2024-12-01 21:46:18.246] Step 4/4 mult
+#> INFO [2024-12-01 21:46:18.248] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.248] Done.
#> $mult
#> [1] 6
#>
@@ -2541,12 +2539,12 @@ Examplesp$add("f1", \(x = 1) x)
p$add("f2", \(y = 1) y)
p$run()
-#> INFO [2024-12-01 21:41:22.493] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.494] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.495] Step 2/3 f1
-#> INFO [2024-12-01 21:41:22.496] Step 3/3 f2
-#> INFO [2024-12-01 21:41:22.498] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.498] Done.
+#> INFO [2024-12-01 21:46:18.264] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.265] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.266] Step 2/3 f1
+#> INFO [2024-12-01 21:46:18.268] Step 3/3 f2
+#> INFO [2024-12-01 21:46:18.269] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.269] Done.
p
#> step depends out keepOut group state
#> <char> <list> <list> <lgcl> <char> <char>
@@ -2571,13 +2569,13 @@ Examplesp$add("add2", \(x = ~add1, z = 2) x + z)
p$add("final", \(x = ~add1, y = ~add2) x * y, keepOut = TRUE)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:22.508] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.509] Step 1/4 data
-#> INFO [2024-12-01 21:41:22.511] Step 2/4 add1
-#> INFO [2024-12-01 21:41:22.513] Step 3/4 add2
-#> INFO [2024-12-01 21:41:22.515] Step 4/4 final
-#> INFO [2024-12-01 21:41:22.516] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.517] Done.
+#> INFO [2024-12-01 21:46:18.280] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.280] Step 1/4 data
+#> INFO [2024-12-01 21:46:18.283] Step 2/4 add1
+#> INFO [2024-12-01 21:46:18.285] Step 3/4 add2
+#> INFO [2024-12-01 21:46:18.287] Step 4/4 final
+#> INFO [2024-12-01 21:46:18.288] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.288] Done.
#> $final
#> [1] 8
#>
@@ -2590,25 +2588,25 @@ Examples#> 3: add2 add1 4 FALSE add2 Outdated
#> 4: final add1,add2 8 TRUE final Outdated
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:22.524] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.525] Step 1/4 data - skip 'done' step
-#> INFO [2024-12-01 21:41:22.526] Step 2/4 add1 - skip 'done' step
-#> INFO [2024-12-01 21:41:22.526] Step 3/4 add2
-#> INFO [2024-12-01 21:41:22.528] Step 4/4 final
-#> INFO [2024-12-01 21:41:22.529] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.530] Done.
+#> INFO [2024-12-01 21:46:18.295] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.296] Step 1/4 data - skip 'done' step
+#> INFO [2024-12-01 21:46:18.297] Step 2/4 add1 - skip 'done' step
+#> INFO [2024-12-01 21:46:18.298] Step 3/4 add2
+#> INFO [2024-12-01 21:46:18.299] Step 4/4 final
+#> INFO [2024-12-01 21:46:18.301] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.301] Done.
#> $final
#> [1] 12
#>
p$run(cleanUnkept = TRUE) # clean up temporary results
-#> INFO [2024-12-01 21:41:22.531] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.532] Step 1/4 data - skip 'done' step
-#> INFO [2024-12-01 21:41:22.533] Step 2/4 add1 - skip 'done' step
-#> INFO [2024-12-01 21:41:22.534] Step 3/4 add2 - skip 'done' step
-#> INFO [2024-12-01 21:41:22.535] Step 4/4 final - skip 'done' step
-#> INFO [2024-12-01 21:41:22.535] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.536] Clean temporary results.
-#> INFO [2024-12-01 21:41:22.536] Done.
+#> INFO [2024-12-01 21:46:18.303] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.303] Step 1/4 data - skip 'done' step
+#> INFO [2024-12-01 21:46:18.304] Step 2/4 add1 - skip 'done' step
+#> INFO [2024-12-01 21:46:18.305] Step 3/4 add2 - skip 'done' step
+#> INFO [2024-12-01 21:46:18.306] Step 4/4 final - skip 'done' step
+#> INFO [2024-12-01 21:46:18.306] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.307] Clean temporary results.
+#> INFO [2024-12-01 21:46:18.307] Done.
p
#> step depends out keepOut group state
#> <char> <list> <list> <lgcl> <char> <char>
@@ -2627,17 +2625,17 @@ Examples }
)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:22.543] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.544] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.546] Step 2/3 add1
-#> INFO [2024-12-01 21:41:22.547] Step 3/3 new_pipe
-#> INFO [2024-12-01 21:41:22.550] Abort pipeline execution and restart on new.
-#> INFO [2024-12-01 21:41:22.551] Start run of 'new_pipe' pipeline:
-#> INFO [2024-12-01 21:41:22.552] Step 1/3 data
-#> INFO [2024-12-01 21:41:22.554] Step 2/3 add1
-#> INFO [2024-12-01 21:41:22.556] Step 3/3 add2
-#> INFO [2024-12-01 21:41:22.557] Finished execution of steps.
-#> INFO [2024-12-01 21:41:22.557] Done.
+#> INFO [2024-12-01 21:46:18.314] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.315] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.317] Step 2/3 add1
+#> INFO [2024-12-01 21:46:18.319] Step 3/3 new_pipe
+#> INFO [2024-12-01 21:46:18.322] Abort pipeline execution and restart on new.
+#> INFO [2024-12-01 21:46:18.322] Start run of 'new_pipe' pipeline:
+#> INFO [2024-12-01 21:46:18.323] Step 1/3 data
+#> INFO [2024-12-01 21:46:18.325] Step 2/3 add1
+#> INFO [2024-12-01 21:46:18.327] Step 3/3 add2
+#> INFO [2024-12-01 21:46:18.328] Finished execution of steps.
+#> INFO [2024-12-01 21:46:18.329] Done.
#> $add2
#> [1] 5
#>
@@ -2663,28 +2661,28 @@ Examplesp$add("add2", \(x = ~add1, z = 2) x + z)
p$add("mult", \(x = ~add1, y = ~add2) x * y)
p$run_step("add2")
-#> INFO [2024-12-01 21:41:25.633] Start step run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.634] Step 1/3 data (upstream)
-#> INFO [2024-12-01 21:41:25.636] Step 2/3 add1 (upstream)
-#> INFO [2024-12-01 21:41:25.638] Step 3/3 add2
-#> INFO [2024-12-01 21:41:25.640] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.640] Done.
+#> INFO [2024-12-01 21:46:21.408] Start step run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.409] Step 1/3 data (upstream)
+#> INFO [2024-12-01 21:46:21.411] Step 2/3 add1 (upstream)
+#> INFO [2024-12-01 21:46:21.413] Step 3/3 add2
+#> INFO [2024-12-01 21:46:21.414] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.415] Done.
p$run_step("add2", downstream = TRUE)
-#> INFO [2024-12-01 21:41:25.655] Start step run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.655] Step 1/4 data (upstream)
-#> INFO [2024-12-01 21:41:25.658] Step 2/4 add1 (upstream)
-#> INFO [2024-12-01 21:41:25.660] Step 3/4 add2
-#> INFO [2024-12-01 21:41:25.664] Step 4/4 mult (downstream)
-#> INFO [2024-12-01 21:41:25.665] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.666] Done.
+#> INFO [2024-12-01 21:46:21.432] Start step run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.432] Step 1/4 data (upstream)
+#> INFO [2024-12-01 21:46:21.434] Step 2/4 add1 (upstream)
+#> INFO [2024-12-01 21:46:21.436] Step 3/4 add2
+#> INFO [2024-12-01 21:46:21.438] Step 4/4 mult (downstream)
+#> INFO [2024-12-01 21:46:21.439] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.439] Done.
p$run_step("mult", upstream = TRUE)
-#> INFO [2024-12-01 21:41:25.667] Start step run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.668] Step 1/4 data (upstream)
-#> INFO [2024-12-01 21:41:25.670] Step 2/4 add1 (upstream)
-#> INFO [2024-12-01 21:41:25.672] Step 3/4 add2 (upstream)
-#> INFO [2024-12-01 21:41:25.674] Step 4/4 mult
-#> INFO [2024-12-01 21:41:25.675] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.675] Done.
+#> INFO [2024-12-01 21:46:21.441] Start step run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.441] Step 1/4 data (upstream)
+#> INFO [2024-12-01 21:46:21.444] Step 2/4 add1 (upstream)
+#> INFO [2024-12-01 21:46:21.446] Step 3/4 add2 (upstream)
+#> INFO [2024-12-01 21:46:21.448] Step 4/4 mult
+#> INFO [2024-12-01 21:46:21.449] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.449] Done.
## ------------------------------------------------
## Method `Pipeline$set_data`
@@ -2693,21 +2691,21 @@ Examplesp <- Pipeline$new("pipe", data = 1)
p$add("add1", \(x = ~data, y = 1) x + y, keepOut = TRUE)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:25.679] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.680] Step 1/2 data
-#> INFO [2024-12-01 21:41:25.682] Step 2/2 add1
-#> INFO [2024-12-01 21:41:25.683] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.684] Done.
+#> INFO [2024-12-01 21:46:21.453] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.454] Step 1/2 data
+#> INFO [2024-12-01 21:46:21.456] Step 2/2 add1
+#> INFO [2024-12-01 21:46:21.457] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.457] Done.
#> $add1
#> [1] 2
#>
p$set_data(3)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:25.687] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.688] Step 1/2 data
-#> INFO [2024-12-01 21:41:25.690] Step 2/2 add1
-#> INFO [2024-12-01 21:41:25.691] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.692] Done.
+#> INFO [2024-12-01 21:46:21.460] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.461] Step 1/2 data
+#> INFO [2024-12-01 21:46:21.464] Step 2/2 add1
+#> INFO [2024-12-01 21:46:21.465] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.465] Done.
#> $add1
#> [1] 4
#>
@@ -2735,18 +2733,18 @@ Examples#> 8: add1.c data.c [NULL] TRUE c Outdated
#> 9: mult.c data.c,add1.c [NULL] TRUE c Outdated
p3$run()$collect_out() |> str()
-#> INFO [2024-12-01 21:41:25.714] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.715] Step 1/9 data.a
-#> INFO [2024-12-01 21:41:25.717] Step 2/9 add1.a
-#> INFO [2024-12-01 21:41:25.719] Step 3/9 mult.a
-#> INFO [2024-12-01 21:41:25.721] Step 4/9 data.b
-#> INFO [2024-12-01 21:41:25.723] Step 5/9 add1.b
-#> INFO [2024-12-01 21:41:25.725] Step 6/9 mult.b
-#> INFO [2024-12-01 21:41:25.726] Step 7/9 data.c
-#> INFO [2024-12-01 21:41:25.728] Step 8/9 add1.c
-#> INFO [2024-12-01 21:41:25.730] Step 9/9 mult.c
-#> INFO [2024-12-01 21:41:25.731] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.732] Done.
+#> INFO [2024-12-01 21:46:21.488] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.488] Step 1/9 data.a
+#> INFO [2024-12-01 21:46:21.490] Step 2/9 add1.a
+#> INFO [2024-12-01 21:46:21.492] Step 3/9 mult.a
+#> INFO [2024-12-01 21:46:21.494] Step 4/9 data.b
+#> INFO [2024-12-01 21:46:21.496] Step 5/9 add1.b
+#> INFO [2024-12-01 21:46:21.498] Step 6/9 mult.b
+#> INFO [2024-12-01 21:46:21.500] Step 7/9 data.c
+#> INFO [2024-12-01 21:46:21.502] Step 8/9 add1.c
+#> INFO [2024-12-01 21:46:21.503] Step 9/9 mult.c
+#> INFO [2024-12-01 21:46:21.505] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.505] Done.
#> List of 3
#> $ a:List of 2
#> ..$ add1.a: num 2
@@ -2776,18 +2774,18 @@ Examples#> 8: add1.c data.c [NULL] TRUE add1.c Outdated
#> 9: mult.c data.c,add1.c [NULL] TRUE mult.c Outdated
p3$run()$collect_out() |> str()
-#> INFO [2024-12-01 21:41:25.757] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.758] Step 1/9 data.a
-#> INFO [2024-12-01 21:41:25.760] Step 2/9 add1.a
-#> INFO [2024-12-01 21:41:25.762] Step 3/9 mult.a
-#> INFO [2024-12-01 21:41:25.764] Step 4/9 data.b
-#> INFO [2024-12-01 21:41:25.766] Step 5/9 add1.b
-#> INFO [2024-12-01 21:41:25.767] Step 6/9 mult.b
-#> INFO [2024-12-01 21:41:25.769] Step 7/9 data.c
-#> INFO [2024-12-01 21:41:25.771] Step 8/9 add1.c
-#> INFO [2024-12-01 21:41:25.773] Step 9/9 mult.c
-#> INFO [2024-12-01 21:41:25.774] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.775] Done.
+#> INFO [2024-12-01 21:46:21.531] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.532] Step 1/9 data.a
+#> INFO [2024-12-01 21:46:21.534] Step 2/9 add1.a
+#> INFO [2024-12-01 21:46:21.536] Step 3/9 mult.a
+#> INFO [2024-12-01 21:46:21.537] Step 4/9 data.b
+#> INFO [2024-12-01 21:46:21.539] Step 5/9 add1.b
+#> INFO [2024-12-01 21:46:21.541] Step 6/9 mult.b
+#> INFO [2024-12-01 21:46:21.543] Step 7/9 data.c
+#> INFO [2024-12-01 21:46:21.545] Step 8/9 add1.c
+#> INFO [2024-12-01 21:46:21.546] Step 9/9 mult.c
+#> INFO [2024-12-01 21:46:21.548] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.548] Done.
#> List of 6
#> $ add1.a: num 2
#> $ mult.a: num 2
@@ -2805,13 +2803,13 @@ Examplesp$add("add2", \(x = ~data, y = 2) x + y)
p$add("mult", \(x = ~add1, y = ~add2) x * y)
p$run()$collect_out()
-#> INFO [2024-12-01 21:41:25.783] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:25.784] Step 1/4 data
-#> INFO [2024-12-01 21:41:25.786] Step 2/4 add1
-#> INFO [2024-12-01 21:41:25.788] Step 3/4 add2
-#> INFO [2024-12-01 21:41:25.790] Step 4/4 mult
-#> INFO [2024-12-01 21:41:25.791] Finished execution of steps.
-#> INFO [2024-12-01 21:41:25.792] Done.
+#> INFO [2024-12-01 21:46:21.557] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:21.558] Step 1/4 data
+#> INFO [2024-12-01 21:46:21.560] Step 2/4 add1
+#> INFO [2024-12-01 21:46:21.562] Step 3/4 add2
+#> INFO [2024-12-01 21:46:21.566] Step 4/4 mult
+#> INFO [2024-12-01 21:46:21.567] Finished execution of steps.
+#> INFO [2024-12-01 21:46:21.568] Done.
#> $add1
#> [1] 2
#>
diff --git a/docs/reference/index.html b/docs/reference/index.html
index 0bdbf62..17d1b0c 100644
--- a/docs/reference/index.html
+++ b/docs/reference/index.html
@@ -37,9 +37,7 @@
- GroupSeq
- pipeflow
-
diff --git a/docs/reference/pipelineAliases.html b/docs/reference/pipelineAliases.html
index 7dfbf8b..bc18f26 100644
--- a/docs/reference/pipelineAliases.html
+++ b/docs/reference/pipelineAliases.html
@@ -39,9 +39,7 @@
- GroupSeq
- pipeflow
-
diff --git a/docs/reference/set_log_layout.html b/docs/reference/set_log_layout.html
index 6efc545..0520c3e 100644
--- a/docs/reference/set_log_layout.html
+++ b/docs/reference/set_log_layout.html
@@ -37,9 +37,7 @@
- GroupSeq
- pipeflow
-
@@ -82,11 +80,11 @@ Examplesp <- Pipeline$new("pipe", data = 1:2)
p$add("add1", \(data = ~data, x = 1) x + data)
p$run()
-#> INFO [2024-12-01 21:41:29.126] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:29.127] Step 1/2 data
-#> INFO [2024-12-01 21:41:29.129] Step 2/2 add1
-#> INFO [2024-12-01 21:41:29.130] Finished execution of steps.
-#> INFO [2024-12-01 21:41:29.131] Done.
+#> INFO [2024-12-01 21:46:24.778] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:24.779] Step 1/2 data
+#> INFO [2024-12-01 21:46:24.781] Step 2/2 add1
+#> INFO [2024-12-01 21:46:24.782] Finished execution of steps.
+#> INFO [2024-12-01 21:46:24.783] Done.
lg <- set_log_layout("json")
print(lg)
@@ -96,19 +94,19 @@ Examples#> [[1]]: <AppenderConsole> [all] -> console
p$run()
-#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:41:29+1:00","message":"Start run of 'pipe' pipeline:"}
-#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:41:29+1:00","message":"Step 1/2 data - skip 'done' step"}
-#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:41:29+1:00","message":"Step 2/2 add1 - skip 'done' step"}
-#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:41:29+1:00","message":"Finished execution of steps."}
-#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:41:29+1:00","message":"Done."}
+#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:46:24+1:00","message":"Start run of 'pipe' pipeline:"}
+#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:46:24+1:00","message":"Step 1/2 data - skip 'done' step"}
+#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:46:24+1:00","message":"Step 2/2 add1 - skip 'done' step"}
+#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:46:24+1:00","message":"Finished execution of steps."}
+#> {"application":"pipeflow","level":"info","time":"2024-12-01T21:46:24+1:00","message":"Done."}
set_log_layout("text")
p$run()
-#> INFO [2024-12-01 21:41:29.169] Start run of 'pipe' pipeline:
-#> INFO [2024-12-01 21:41:29.170] Step 1/2 data - skip 'done' step
-#> INFO [2024-12-01 21:41:29.171] Step 2/2 add1 - skip 'done' step
-#> INFO [2024-12-01 21:41:29.171] Finished execution of steps.
-#> INFO [2024-12-01 21:41:29.172] Done.
+#> INFO [2024-12-01 21:46:24.821] Start run of 'pipe' pipeline:
+#> INFO [2024-12-01 21:46:24.822] Step 1/2 data - skip 'done' step
+#> INFO [2024-12-01 21:46:24.823] Step 2/2 add1 - skip 'done' step
+#> INFO [2024-12-01 21:46:24.823] Finished execution of steps.
+#> INFO [2024-12-01 21:46:24.824] Done.