Skip to main content
Back to top
Ctrl
+
K
dplutils 0.8.2
Quick Start
Usage
Tasks and Pipeline Graphs
Configuring Pipelines
Executing Pipelines
Observing
Executing via CLI
Extending Functionality
API
Pipeline
dplutils.pipeline.PipelineExecutor
dplutils.pipeline.PipelineTask
dplutils.pipeline.PipelineGraph
dplutils.pipeline.stream.StreamingGraphExecutor
dplutils.pipeline.ray.RayDataPipelineExecutor
dplutils.pipeline.ray.RayStreamGraphExecutor
Observers
dplutils.observer.set_observer
dplutils.observer.get_observer
dplutils.observer.observe
dplutils.observer.increment
dplutils.observer.param
dplutils.observer.timer
dplutils.observer.Observer
dplutils.observer.Observer.observe
dplutils.observer.ray.RayActorWrappedObserver
dplutils.observer.ray.RayMetricsObserver
dplutils.observer.aim.AimObserver
dplutils.observer.mlflow.MlflowObserver
CLI
dplutils.cli.cli_run
dplutils.cli.get_argparser
dplutils.cli.set_config_from_args
dplutils.cli.add_generic_args
dplutils.pipeline.stream.StreamingGraphExecutor.is_task_ready
dplutils.pipeline.stream.StreamingGraphExecutor.poll_tasks
dplutils.pipeline.stream.StreamingGraphExecutor.split_batch_submit
dplutils.pipeline.stream.StreamingGraphExecutor.task_resolve_output
dplutils.pipeline.stream.StreamingGraphExecutor.task_submit
dplutils.pipeline.stream.StreamingGraphExecutor.task_submittable
.rst
.pdf
Extending Functionality
Extending Functionality
#
TBD
