LICENSE
README.md
pyproject.toml
src/datapipeline/__init__.py
src/datapipeline/plugins.py
src/datapipeline/runtime.py
src/datapipeline/alignment/__init__.py
src/datapipeline/alignment/broadcast.py
src/datapipeline/alignment/engine.py
src/datapipeline/analysis/__init__.py
src/datapipeline/analysis/vector/coverage_stats.py
src/datapipeline/analysis/vector/matrix.py
src/datapipeline/artifacts/__init__.py
src/datapipeline/artifacts/errors.py
src/datapipeline/artifacts/executor.py
src/datapipeline/artifacts/fingerprints.py
src/datapipeline/artifacts/hydration.py
src/datapipeline/artifacts/models.py
src/datapipeline/artifacts/planning.py
src/datapipeline/artifacts/registry.py
src/datapipeline/artifacts/scaler.py
src/datapipeline/artifacts/series.py
src/datapipeline/artifacts/settings.py
src/datapipeline/artifacts/specs.py
src/datapipeline/artifacts/ticks.py
src/datapipeline/artifacts/validation.py
src/datapipeline/build/__init__.py
src/datapipeline/build/state.py
src/datapipeline/cli/app.py
src/datapipeline/cli/command_router.py
src/datapipeline/cli/logging_setup.py
src/datapipeline/cli/output_options.py
src/datapipeline/cli/parser_builder.py
src/datapipeline/cli/prompts.py
src/datapipeline/cli/source_options.py
src/datapipeline/cli/version.py
src/datapipeline/cli/workspace.py
src/datapipeline/cli/commands/clean.py
src/datapipeline/cli/commands/demo.py
src/datapipeline/cli/commands/domain.py
src/datapipeline/cli/commands/dto.py
src/datapipeline/cli/commands/inflow.py
src/datapipeline/cli/commands/list_.py
src/datapipeline/cli/commands/loader.py
src/datapipeline/cli/commands/mapper.py
src/datapipeline/cli/commands/materialize.py
src/datapipeline/cli/commands/parser.py
src/datapipeline/cli/commands/plugin.py
src/datapipeline/cli/commands/profile_runner.py
src/datapipeline/cli/commands/source.py
src/datapipeline/cli/commands/stream.py
src/datapipeline/cli/commands/version.py
src/datapipeline/cli/parser/__init__.py
src/datapipeline/cli/parser/build.py
src/datapipeline/cli/parser/clean.py
src/datapipeline/cli/parser/common.py
src/datapipeline/cli/parser/demo.py
src/datapipeline/cli/parser/domain.py
src/datapipeline/cli/parser/inflow.py
src/datapipeline/cli/parser/inspect.py
src/datapipeline/cli/parser/list_.py
src/datapipeline/cli/parser/materialize.py
src/datapipeline/cli/parser/plugin.py
src/datapipeline/cli/parser/scaffold.py
src/datapipeline/cli/parser/serve.py
src/datapipeline/cli/parser/source.py
src/datapipeline/cli/parser/stream.py
src/datapipeline/cli/visuals/__init__.py
src/datapipeline/cli/visuals/execution.py
src/datapipeline/cli/visuals/execution_context.py
src/datapipeline/cli/visuals/rich/__init__.py
src/datapipeline/cli/visuals/rich/progress.py
src/datapipeline/config/__init__.py
src/datapipeline/config/execution.py
src/datapipeline/config/observability.py
src/datapipeline/config/options.py
src/datapipeline/config/preview.py
src/datapipeline/config/project.py
src/datapipeline/config/sources.py
src/datapipeline/config/streams.py
src/datapipeline/config/transforms.py
src/datapipeline/config/workspace.py
src/datapipeline/config/dataset/dataset.py
src/datapipeline/config/dataset/postprocess.py
src/datapipeline/config/dataset/series.py
src/datapipeline/config/dataset/split.py
src/datapipeline/config/profiles/__init__.py
src/datapipeline/config/profiles/base.py
src/datapipeline/config/profiles/build.py
src/datapipeline/config/profiles/defaults.py
src/datapipeline/config/profiles/inspect.py
src/datapipeline/config/profiles/materialize.py
src/datapipeline/config/profiles/output.py
src/datapipeline/config/profiles/serve.py
src/datapipeline/config/tasks/__init__.py
src/datapipeline/config/tasks/base.py
src/datapipeline/config/tasks/coverage.py
src/datapipeline/config/tasks/coverage_stats.py
src/datapipeline/config/tasks/dataset.py
src/datapipeline/config/tasks/matrix.py
src/datapipeline/config/tasks/metadata.py
src/datapipeline/config/tasks/scaler.py
src/datapipeline/config/tasks/series.py
src/datapipeline/config/tasks/ticks.py
src/datapipeline/domain/__init__.py
src/datapipeline/domain/record.py
src/datapipeline/domain/sample.py
src/datapipeline/domain/sample_key.py
src/datapipeline/domain/series.py
src/datapipeline/domain/series_id.py
src/datapipeline/domain/stream.py
src/datapipeline/domain/value.py
src/datapipeline/domain/vector.py
src/datapipeline/execution/__init__.py
src/datapipeline/execution/context.py
src/datapipeline/execution/events.py
src/datapipeline/execution/observability.py
src/datapipeline/execution/observer.py
src/datapipeline/execution/pipeline.py
src/datapipeline/execution/runner.py
src/datapipeline/execution/settings.py
src/datapipeline/integrations/__init__.py
src/datapipeline/integrations/ml.py
src/datapipeline/io/compression.py
src/datapipeline/io/csv_projection.py
src/datapipeline/io/dataset_table.py
src/datapipeline/io/factory.py
src/datapipeline/io/normalization.py
src/datapipeline/io/output.py
src/datapipeline/io/protocols.py
src/datapipeline/io/runs.py
src/datapipeline/io/serializers.py
src/datapipeline/io/sinks/__init__.py
src/datapipeline/io/sinks/files.py
src/datapipeline/io/sinks/stdout.py
src/datapipeline/io/writers/__init__.py
src/datapipeline/io/writers/base.py
src/datapipeline/io/writers/csv_writer.py
src/datapipeline/io/writers/jsonl.py
src/datapipeline/io/writers/parquet.py
src/datapipeline/io/writers/pickle_writer.py
src/datapipeline/mappers/noop.py
src/datapipeline/mappers/synthetic/time.py
src/datapipeline/operations/__init__.py
src/datapipeline/operations/persistence.py
src/datapipeline/operations/artifacts/__init__.py
src/datapipeline/operations/artifacts/coverage_stats.py
src/datapipeline/operations/artifacts/metadata.py
src/datapipeline/operations/artifacts/scaler.py
src/datapipeline/operations/artifacts/series.py
src/datapipeline/operations/artifacts/ticks.py
src/datapipeline/operations/artifacts/utils.py
src/datapipeline/operations/runtime/__init__.py
src/datapipeline/operations/runtime/coverage.py
src/datapipeline/operations/runtime/dataset.py
src/datapipeline/operations/runtime/matrix.py
src/datapipeline/parsers/identity.py
src/datapipeline/parsers/temporal_record.py
src/datapipeline/pipelines/__init__.py
src/datapipeline/pipelines/sort.py
src/datapipeline/pipelines/dataset/__init__.py
src/datapipeline/pipelines/dataset/pipeline.py
src/datapipeline/pipelines/dataset/postprocess.py
src/datapipeline/pipelines/dataset/split.py
src/datapipeline/pipelines/sample/__init__.py
src/datapipeline/pipelines/sample/input.py
src/datapipeline/pipelines/sample/keys.py
src/datapipeline/pipelines/series/__init__.py
src/datapipeline/pipelines/series/pipeline.py
src/datapipeline/pipelines/series/projector.py
src/datapipeline/pipelines/series/stages.py
src/datapipeline/pipelines/stream/__init__.py
src/datapipeline/pipelines/stream/order.py
src/datapipeline/pipelines/stream/pipeline.py
src/datapipeline/pipelines/stream/stages.py
src/datapipeline/profiles/__init__.py
src/datapipeline/profiles/execution.py
src/datapipeline/profiles/executor.py
src/datapipeline/profiles/loader.py
src/datapipeline/profiles/materialize.py
src/datapipeline/profiles/models.py
src/datapipeline/profiles/orchestration.py
src/datapipeline/profiles/request_builder.py
src/datapipeline/profiles/runtime_profiles.py
src/datapipeline/services/config_inventory.py
src/datapipeline/services/config_refs.py
src/datapipeline/services/dataset.py
src/datapipeline/services/definitions.py
src/datapipeline/services/execution_lock.py
src/datapipeline/services/materialize.py
src/datapipeline/services/operations.py
src/datapipeline/services/path_policy.py
src/datapipeline/services/project.py
src/datapipeline/services/project_definition.py
src/datapipeline/services/runtime_compiler.py
src/datapipeline/services/temp_cleanup.py
src/datapipeline/services/scaffold/__init__.py
src/datapipeline/services/scaffold/demo.py
src/datapipeline/services/scaffold/discovery.py
src/datapipeline/services/scaffold/domain.py
src/datapipeline/services/scaffold/dto.py
src/datapipeline/services/scaffold/entrypoints.py
src/datapipeline/services/scaffold/layout.py
src/datapipeline/services/scaffold/loader.py
src/datapipeline/services/scaffold/locking.py
src/datapipeline/services/scaffold/mapper.py
src/datapipeline/services/scaffold/parser.py
src/datapipeline/services/scaffold/paths.py
src/datapipeline/services/scaffold/plugin.py
src/datapipeline/services/scaffold/source_yaml.py
src/datapipeline/services/scaffold/stream_plan.py
src/datapipeline/services/scaffold/stream_yaml.py
src/datapipeline/services/scaffold/templates.py
src/datapipeline/services/scaffold/utils.py
src/datapipeline/services/streams/combine.py
src/datapipeline/services/streams/loader.py
src/datapipeline/services/streams/source.py
src/datapipeline/services/streams/validation.py
src/datapipeline/sources/__init__.py
src/datapipeline/sources/decoders.py
src/datapipeline/sources/factory.py
src/datapipeline/sources/loader.py
src/datapipeline/sources/observability.py
src/datapipeline/sources/parquet_loader.py
src/datapipeline/sources/parser.py
src/datapipeline/sources/ports.py
src/datapipeline/sources/source.py
src/datapipeline/sources/adapters/__init__.py
src/datapipeline/sources/adapters/fs.py
src/datapipeline/sources/adapters/http.py
src/datapipeline/sources/synthetic/__init__.py
src/datapipeline/sources/synthetic/time/__init__.py
src/datapipeline/sources/synthetic/time/loader.py
src/datapipeline/sources/synthetic/time/parser.py
src/datapipeline/templates/dataset_skeleton/README.md
src/datapipeline/templates/dataset_skeleton/jerry.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/.env.example
src/datapipeline/templates/dataset_skeleton/your-dataset/dataset.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/project.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/profiles/inspect.coverage.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/profiles/inspect.matrix.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/profiles/serve.dataset.yaml
src/datapipeline/templates/dataset_skeleton/your-dataset/profiles/serve.defaults.yaml
src/datapipeline/templates/demo_skeleton/README.md
src/datapipeline/templates/demo_skeleton/jerry.yaml
src/datapipeline/templates/demo_skeleton/demo/.env.example
src/datapipeline/templates/demo_skeleton/demo/dataset.yaml
src/datapipeline/templates/demo_skeleton/demo/project.yaml
src/datapipeline/templates/demo_skeleton/demo/data/AAPL.jsonl
src/datapipeline/templates/demo_skeleton/demo/data/MSFT.jsonl
src/datapipeline/templates/demo_skeleton/demo/profiles/build.defaults.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/build.metadata.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/build.scaler.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/build.series.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/inspect.coverage.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/inspect.defaults.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/inspect.matrix.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/serve.dataset.yaml
src/datapipeline/templates/demo_skeleton/demo/profiles/serve.defaults.yaml
src/datapipeline/templates/demo_skeleton/demo/scripts/run_model_batches.py
src/datapipeline/templates/demo_skeleton/demo/sources/sandbox.ohlcv.yaml
src/datapipeline/templates/demo_skeleton/demo/sources/synthetic.ticks.yaml
src/datapipeline/templates/demo_skeleton/demo/streams/equity.aapl.yaml
src/datapipeline/templates/demo_skeleton/demo/streams/equity.msft.yaml
src/datapipeline/templates/demo_skeleton/demo/streams/equity.ohlcv.yaml
src/datapipeline/templates/demo_skeleton/demo/streams/time.ticks.hour_sin.yaml
src/datapipeline/templates/demo_skeleton/demo/streams/time.ticks.linear.yaml
src/datapipeline/templates/demo_skeleton/src/demo/domains/equity/__init__.py
src/datapipeline/templates/demo_skeleton/src/demo/domains/equity/model.py
src/datapipeline/templates/demo_skeleton/src/demo/dtos/sandbox_ohlcv_dto.py
src/datapipeline/templates/demo_skeleton/src/demo/mappers/map_sandbox_ohlcv_dto_to_equity.py
src/datapipeline/templates/demo_skeleton/src/demo/parsers/sandbox_ohlcv_dto_parser.py
src/datapipeline/templates/plugin_skeleton/.gitignore
src/datapipeline/templates/plugin_skeleton/pyproject.toml
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/combiners/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/domains/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/dtos/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/loaders/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/mappers/__init__.py
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/parsers/__init__.py
src/datapipeline/templates/stubs/dto.py.j2
src/datapipeline/templates/stubs/parser.py.j2
src/datapipeline/templates/stubs/record.py.j2
src/datapipeline/templates/stubs/source.yaml.j2
src/datapipeline/templates/stubs/loaders/basic.py.j2
src/datapipeline/templates/stubs/mappers/source.py.j2
src/datapipeline/templates/stubs/streams/aligned.yaml.j2
src/datapipeline/templates/stubs/streams/broadcast.yaml.j2
src/datapipeline/templates/stubs/streams/source.yaml.j2
src/datapipeline/transforms/rolling_slope.py
src/datapipeline/transforms/rolling_window.py
src/datapipeline/transforms/time.py
src/datapipeline/transforms/utils.py
src/datapipeline/transforms/where.py
src/datapipeline/transforms/stream/collapse.py
src/datapipeline/transforms/stream/dedupe.py
src/datapipeline/transforms/stream/derive.py
src/datapipeline/transforms/stream/ensure_ticks.py
src/datapipeline/transforms/stream/fill.py
src/datapipeline/transforms/stream/forward_sum.py
src/datapipeline/transforms/stream/lag.py
src/datapipeline/transforms/stream/lead.py
src/datapipeline/transforms/stream/logarithm.py
src/datapipeline/transforms/stream/rolling.py
src/datapipeline/transforms/stream/rolling_slope.py
src/datapipeline/transforms/vector/__init__.py
src/datapipeline/transforms/vector/common.py
src/datapipeline/transforms/vector/conform.py
src/datapipeline/transforms/vector/scaler.py
src/datapipeline/transforms/vector/drop/__init__.py
src/datapipeline/transforms/vector/drop/horizontal.py
src/datapipeline/transforms/vector/drop/vertical.py
src/datapipeline/utils/__init__.py
src/datapipeline/utils/json_artifact.py
src/datapipeline/utils/load.py
src/datapipeline/utils/placeholders.py
src/datapipeline/utils/time.py
src/datapipeline/utils/window.py
src/jerry_thomas.egg-info/PKG-INFO
src/jerry_thomas.egg-info/SOURCES.txt
src/jerry_thomas.egg-info/dependency_links.txt
src/jerry_thomas.egg-info/entry_points.txt
src/jerry_thomas.egg-info/requires.txt
src/jerry_thomas.egg-info/top_level.txt