LICENSE
README.md
pyproject.toml
src/datapipeline/__init__.py
src/datapipeline/plugins.py
src/datapipeline/runtime.py
src/datapipeline/analysis/__init__.py
src/datapipeline/analysis/vector_analyzer.py
src/datapipeline/analysis/vector/collector.py
src/datapipeline/analysis/vector/matrix.py
src/datapipeline/analysis/vector/report.py
src/datapipeline/build/__init__.py
src/datapipeline/build/state.py
src/datapipeline/build/tasks/__init__.py
src/datapipeline/build/tasks/config.py
src/datapipeline/build/tasks/metadata.py
src/datapipeline/build/tasks/scaler.py
src/datapipeline/build/tasks/schema.py
src/datapipeline/build/tasks/utils.py
src/datapipeline/cli/app.py
src/datapipeline/cli/workspace_utils.py
src/datapipeline/cli/commands/build.py
src/datapipeline/cli/commands/contract.py
src/datapipeline/cli/commands/demo.py
src/datapipeline/cli/commands/domain.py
src/datapipeline/cli/commands/dto.py
src/datapipeline/cli/commands/filter.py
src/datapipeline/cli/commands/inspect.py
src/datapipeline/cli/commands/list_.py
src/datapipeline/cli/commands/loader.py
src/datapipeline/cli/commands/mapper.py
src/datapipeline/cli/commands/parser.py
src/datapipeline/cli/commands/plugin.py
src/datapipeline/cli/commands/run.py
src/datapipeline/cli/commands/run_config.py
src/datapipeline/cli/commands/serve_pipeline.py
src/datapipeline/cli/commands/source.py
src/datapipeline/cli/commands/stream.py
src/datapipeline/cli/visuals/__init__.py
src/datapipeline/cli/visuals/common.py
src/datapipeline/cli/visuals/labels.py
src/datapipeline/cli/visuals/runner.py
src/datapipeline/cli/visuals/sections.py
src/datapipeline/cli/visuals/sources.py
src/datapipeline/cli/visuals/sources_basic.py
src/datapipeline/cli/visuals/sources_off.py
src/datapipeline/cli/visuals/sources_rich.py
src/datapipeline/config/__init__.py
src/datapipeline/config/catalog.py
src/datapipeline/config/context.py
src/datapipeline/config/metadata.py
src/datapipeline/config/options.py
src/datapipeline/config/postprocess.py
src/datapipeline/config/project.py
src/datapipeline/config/resolution.py
src/datapipeline/config/split.py
src/datapipeline/config/tasks.py
src/datapipeline/config/workspace.py
src/datapipeline/config/dataset/dataset.py
src/datapipeline/config/dataset/feature.py
src/datapipeline/config/dataset/loader.py
src/datapipeline/config/dataset/normalize.py
src/datapipeline/domain/__init__.py
src/datapipeline/domain/feature.py
src/datapipeline/domain/record.py
src/datapipeline/domain/sample.py
src/datapipeline/domain/vector.py
src/datapipeline/filters/filters.py
src/datapipeline/integrations/__init__.py
src/datapipeline/integrations/ml/__init__.py
src/datapipeline/integrations/ml/adapter.py
src/datapipeline/integrations/ml/pandas_support.py
src/datapipeline/integrations/ml/rows.py
src/datapipeline/integrations/ml/torch_support.py
src/datapipeline/io/factory.py
src/datapipeline/io/output.py
src/datapipeline/io/protocols.py
src/datapipeline/io/serializers.py
src/datapipeline/io/sinks/__init__.py
src/datapipeline/io/sinks/base.py
src/datapipeline/io/sinks/files.py
src/datapipeline/io/sinks/rich.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/pickle_writer.py
src/datapipeline/mappers/noop.py
src/datapipeline/mappers/synthetic/time.py
src/datapipeline/parsers/identity.py
src/datapipeline/pipeline/__init__.py
src/datapipeline/pipeline/artifacts.py
src/datapipeline/pipeline/context.py
src/datapipeline/pipeline/observability.py
src/datapipeline/pipeline/pipelines.py
src/datapipeline/pipeline/split.py
src/datapipeline/pipeline/stages.py
src/datapipeline/pipeline/utils/keygen.py
src/datapipeline/pipeline/utils/memory_sort.py
src/datapipeline/pipeline/utils/ordering.py
src/datapipeline/pipeline/utils/spool_cache.py
src/datapipeline/pipeline/utils/transform_utils.py
src/datapipeline/registries/registry.py
src/datapipeline/services/artifacts.py
src/datapipeline/services/constants.py
src/datapipeline/services/entrypoints.py
src/datapipeline/services/factories.py
src/datapipeline/services/path_policy.py
src/datapipeline/services/paths.py
src/datapipeline/services/project_paths.py
src/datapipeline/services/runs.py
src/datapipeline/services/bootstrap/__init__.py
src/datapipeline/services/bootstrap/config.py
src/datapipeline/services/bootstrap/core.py
src/datapipeline/services/scaffold/__init__.py
src/datapipeline/services/scaffold/contract_yaml.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/filter.py
src/datapipeline/services/scaffold/layout.py
src/datapipeline/services/scaffold/loader.py
src/datapipeline/services/scaffold/mapper.py
src/datapipeline/services/scaffold/parser.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/templates.py
src/datapipeline/services/scaffold/utils.py
src/datapipeline/sources/__init__.py
src/datapipeline/sources/data_loader.py
src/datapipeline/sources/decoders.py
src/datapipeline/sources/factory.py
src/datapipeline/sources/foreach.py
src/datapipeline/sources/transports.py
src/datapipeline/sources/models/__init__.py
src/datapipeline/sources/models/base.py
src/datapipeline/sources/models/generator.py
src/datapipeline/sources/models/loader.py
src/datapipeline/sources/models/parser.py
src/datapipeline/sources/models/parsing_error.py
src/datapipeline/sources/models/source.py
src/datapipeline/sources/models/synthetic.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/demo_skeleton/demo/dataset.yaml
src/datapipeline/templates/demo_skeleton/demo/postprocess.yaml
src/datapipeline/templates/demo_skeleton/demo/project.yaml
src/datapipeline/templates/demo_skeleton/demo/contracts/equity.ohlcv.yaml
src/datapipeline/templates/demo_skeleton/demo/contracts/time.ticks.hour_sin.yaml
src/datapipeline/templates/demo_skeleton/demo/contracts/time.ticks.linear.yaml
src/datapipeline/templates/demo_skeleton/demo/data/APPL.jsonl
src/datapipeline/templates/demo_skeleton/demo/data/MSFT.jsonl
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/tasks/metadata.yaml
src/datapipeline/templates/demo_skeleton/demo/tasks/scaler.yaml
src/datapipeline/templates/demo_skeleton/demo/tasks/schema.yaml
src/datapipeline/templates/demo_skeleton/demo/tasks/serve.test.yaml
src/datapipeline/templates/demo_skeleton/demo/tasks/serve.train.yaml
src/datapipeline/templates/demo_skeleton/demo/tasks/serve.val.yaml
src/datapipeline/templates/demo_skeleton/scripts/run_dataframe.py
src/datapipeline/templates/demo_skeleton/scripts/run_torch.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/__init__.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/domains/equity/__init__.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/domains/equity/model.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/dtos/__init__.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/dtos/sandbox_ohlcv_dto.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/mappers/__init__.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/mappers/map_sandbox_ohlcv_dto_to_equity.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/parsers/__init__.py
src/datapipeline/templates/demo_skeleton/src/{{PACKAGE_NAME}}/parsers/sandbox_ohlcv_dto_parser.py
src/datapipeline/templates/plugin_skeleton/README.md
src/datapipeline/templates/plugin_skeleton/jerry.yaml
src/datapipeline/templates/plugin_skeleton/pyproject.toml
src/datapipeline/templates/plugin_skeleton/reference/jerry.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/dataset.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/postprocess.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/project.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/contracts/composed.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/contracts/ingest.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/contracts/overview.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/foreach.http.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/foreach.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/fs.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/http.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/overview.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/sources/synthetic.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/tasks/metadata.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/tasks/scaler.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/tasks/schema.reference.yaml
src/datapipeline/templates/plugin_skeleton/reference/reference/tasks/serve.reference.yaml
src/datapipeline/templates/plugin_skeleton/src/{{PACKAGE_NAME}}/__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/plugin_skeleton/your-dataset/dataset.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/postprocess.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/project.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/metadata.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/scaler.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/schema.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/serve.test.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/serve.train.yaml
src/datapipeline/templates/plugin_skeleton/your-dataset/tasks/serve.val.yaml
src/datapipeline/templates/plugin_skeleton/your-interim-data-builder/dataset.yaml
src/datapipeline/templates/plugin_skeleton/your-interim-data-builder/postprocess.yaml
src/datapipeline/templates/plugin_skeleton/your-interim-data-builder/project.yaml
src/datapipeline/templates/plugin_skeleton/your-interim-data-builder/tasks/serve.all.yaml
src/datapipeline/templates/stubs/dto.py.j2
src/datapipeline/templates/stubs/filter.py.j2
src/datapipeline/templates/stubs/loader_synthetic.py.j2
src/datapipeline/templates/stubs/parser.py.j2
src/datapipeline/templates/stubs/parser_custom.py.j2
src/datapipeline/templates/stubs/record.py.j2
src/datapipeline/templates/stubs/source.yaml.j2
src/datapipeline/templates/stubs/contracts/composed.yaml.j2
src/datapipeline/templates/stubs/contracts/ingest.yaml.j2
src/datapipeline/templates/stubs/loaders/basic.py.j2
src/datapipeline/templates/stubs/mappers/composed.py.j2
src/datapipeline/templates/stubs/mappers/ingest.py.j2
src/datapipeline/transforms/filter.py
src/datapipeline/transforms/interfaces.py
src/datapipeline/transforms/sequence.py
src/datapipeline/transforms/utils.py
src/datapipeline/transforms/vector_utils.py
src/datapipeline/transforms/debug/identity.py
src/datapipeline/transforms/debug/lint.py
src/datapipeline/transforms/feature/model.py
src/datapipeline/transforms/feature/scaler.py
src/datapipeline/transforms/record/floor_time.py
src/datapipeline/transforms/record/lag.py
src/datapipeline/transforms/stream/dedupe.py
src/datapipeline/transforms/stream/ensure_ticks.py
src/datapipeline/transforms/stream/fill.py
src/datapipeline/transforms/stream/filter.py
src/datapipeline/transforms/stream/floor_time.py
src/datapipeline/transforms/stream/granularity.py
src/datapipeline/transforms/stream/lag.py
src/datapipeline/transforms/stream/rolling.py
src/datapipeline/transforms/vector/__init__.py
src/datapipeline/transforms/vector/common.py
src/datapipeline/transforms/vector/ensure_schema.py
src/datapipeline/transforms/vector/fill.py
src/datapipeline/transforms/vector/replace.py
src/datapipeline/transforms/vector/drop/__init__.py
src/datapipeline/transforms/vector/drop/horizontal.py
src/datapipeline/transforms/vector/drop/orchestrator.py
src/datapipeline/transforms/vector/drop/vertical.py
src/datapipeline/utils/__init__.py
src/datapipeline/utils/load.py
src/datapipeline/utils/paths.py
src/datapipeline/utils/pickle_model.py
src/datapipeline/utils/placeholders.py
src/datapipeline/utils/rich_compat.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