Namespace of various utilities to test pipelines.
Namespace of various utilities to test pipelines.
(generate p)
(generate values p)
(generate values options p)
Like datasplash.api/generate-input
but uses a unique name.
Useful in TestPipeline where ptranforms cannot have the same name.
Like `datasplash.api/generate-input` but uses a unique name. Useful in TestPipeline where ptranforms **cannot** have the same name.
(run-test-pipeline topology)
Runs a Pipeline and waits until it finishes to assert execution state.
Runs a Pipeline and waits until it finishes to assert execution state.
(with-test-pipeline bindings & body)
Syntactic sugar to run a test pipeline. Use bindings vector to initialize options and create a pipeline. The pipeline creation must be the last binding.
(with-test-pipeline [p (test-pipeline)]
(generate [:a :b :c] p))
Syntactic sugar to run a test pipeline. Use bindings vector to initialize options and create a pipeline. The pipeline creation must be the last binding. ``` (with-test-pipeline [p (test-pipeline)] (generate [:a :b :c] p)) ```
cljdoc is a website building & hosting documentation for Clojure/Script libraries
× close