LICENSE
README.md
pyproject.toml
incorporator/__init__.py
incorporator/base.py
incorporator/exceptions.py
incorporator/list.py
incorporator/rejects.py
incorporator/usercode.py
incorporator.egg-info/PKG-INFO
incorporator.egg-info/SOURCES.txt
incorporator.egg-info/dependency_links.txt
incorporator.egg-info/entry_points.txt
incorporator.egg-info/requires.txt
incorporator.egg-info/top_level.txt
incorporator/_deps/__init__.py
incorporator/_deps/_registry.py
incorporator/_deps/_types.py
incorporator/_deps/cramjam.py
incorporator/_deps/fastavro.py
incorporator/_deps/lxml.py
incorporator/_deps/openpyxl.py
incorporator/_deps/orjson.py
incorporator/_deps/prefect.py
incorporator/_deps/pyarrow.py
incorporator/_deps/typer.py
incorporator/_deps/tzdata.py
incorporator/cli/__init__.py
incorporator/cli/_pipeline_config.py
incorporator/cli/deps.py
incorporator/cli/envexpand.py
incorporator/cli/runners.py
incorporator/cli/scaffold.py
incorporator/cli/tideweaver.py
incorporator/cli/tokens.py
incorporator/cli/validate.py
incorporator/integrations/__init__.py
incorporator/integrations/prefect.py
incorporator/io/__init__.py
incorporator/io/compression.py
incorporator/io/fetch.py
incorporator/io/formats.py
incorporator/io/penstock.py
incorporator/io/source_ref.py
incorporator/io/handlers/__init__.py
incorporator/io/handlers/_base.py
incorporator/io/handlers/binary.py
incorporator/io/handlers/columnar.py
incorporator/io/handlers/delimited.py
incorporator/io/handlers/markup.py
incorporator/io/handlers/spreadsheet.py
incorporator/io/handlers/text.py
incorporator/io/pagination/__init__.py
incorporator/io/pagination/base.py
incorporator/io/pagination/local.py
incorporator/io/pagination/web.py
incorporator/observability/__init__.py
incorporator/observability/logger.py
incorporator/observability/wave.py
incorporator/observability/pipeline/__init__.py
incorporator/observability/pipeline/_daemons.py
incorporator/observability/pipeline/_dispatch.py
incorporator/observability/pipeline/_outflow.py
incorporator/observability/pipeline/_shared.py
incorporator/observability/pipeline/_stateful_shim.py
incorporator/observability/pipeline/chunked.py
incorporator/observability/pipeline/fjord.py
incorporator/observability/tideweaver/__init__.py
incorporator/observability/tideweaver/_retry_defaults.py
incorporator/observability/tideweaver/architect.py
incorporator/observability/tideweaver/config.py
incorporator/observability/tideweaver/current.py
incorporator/observability/tideweaver/current_outcome.py
incorporator/observability/tideweaver/flow.py
incorporator/observability/tideweaver/logged.py
incorporator/observability/tideweaver/reasons.py
incorporator/observability/tideweaver/scheduler.py
incorporator/observability/tideweaver/tide.py
incorporator/observability/tideweaver/watershed.py
incorporator/schema/__init__.py
incorporator/schema/builder.py
incorporator/schema/converters.py
incorporator/schema/directives.py
incorporator/schema/extractors.py
incorporator/schema/factory.py
incorporator/schema/kind.py
incorporator/schema/path.py
incorporator/schema/router.py
incorporator/tools/__init__.py
incorporator/tools/inspector.py
tests/test_append_fallback.py
tests/test_architect.py
tests/test_architect_tune.py
tests/test_atomic_writes.py
tests/test_binary_handlers.py
tests/test_bulk_inc_dict.py
tests/test_canal_reject_telemetry.py
tests/test_chunk_size_aimd.py
tests/test_cli.py
tests/test_cli_directives_integration.py
tests/test_cli_envexpand.py
tests/test_cli_tideweaver.py
tests/test_cli_tokens.py
tests/test_cli_validate.py
tests/test_compression.py
tests/test_converters.py
tests/test_deps_public_api.py
tests/test_extractors_and_list.py
tests/test_fetch_streaming.py
tests/test_fjord.py
tests/test_fjord_multi_output.py
tests/test_flush_passthrough.py
tests/test_format_boundaries.py
tests/test_format_parsers.py
tests/test_format_roundtrip.py
tests/test_handlers_feather.py
tests/test_handlers_html.py
tests/test_handlers_orc.py
tests/test_handlers_parquet.py
tests/test_handlers_text.py
tests/test_handlers_xlsx.py
tests/test_inflow_outflow.py
tests/test_inflow_state.py
tests/test_inspector.py
tests/test_inspector_capture.py
tests/test_io_fetch.py
tests/test_io_pagination_penstock.py
tests/test_io_penstock.py
tests/test_local_json.py
tests/test_logged_tideweaver.py
tests/test_logger.py
tests/test_logger_disk_readers.py
tests/test_logger_reject_routing.py
tests/test_logger_rotation.py
tests/test_logger_tide_routing.py
tests/test_normalize_etl_kwargs.py
tests/test_outcome_record_construct.py
tests/test_outcome_record_schema.py
tests/test_paginators.py
tests/test_paginators_local.py
tests/test_paginators_web.py
tests/test_penstock_cooldown.py
tests/test_penstock_registry.py
tests/test_pipeline.py
tests/test_pipeline_config.py
tests/test_pipeline_dispatch.py
tests/test_pk_bind_cases.py
tests/test_post_tokens.py
tests/test_prefect_nodes.py
tests/test_refresh.py
tests/test_refresh_etl.py
tests/test_rejects.py
tests/test_scheduler_backlog_short_circuit.py
tests/test_scheduler_tick_retry_telemetry.py
tests/test_schema_builder.py
tests/test_schema_directives.py
tests/test_security.py
tests/test_security_compression.py
tests/test_source_ref.py
tests/test_stream.py
tests/test_tide_currentoutcome.py
tests/test_tideweaver.py
tests/test_tideweaver_cli_logs.py
tests/test_tideweaver_custom_autopark.py
tests/test_tideweaver_dedup.py
tests/test_tideweaver_empty_output_warn.py
tests/test_tideweaver_parent_child_audit.py
tests/test_tideweaver_parent_child_fjord.py
tests/test_tideweaver_parent_child_stream.py
tests/test_tideweaver_routing_canal.py
tests/test_tideweaver_routing_chain.py
tests/test_tideweaver_routing_custom.py
tests/test_tideweaver_routing_diamond.py
tests/test_tideweaver_routing_fanout.py
tests/test_tideweaver_routing_parallel.py
tests/test_tideweaver_tune_parent_child.py
tests/test_validation.py
tests/test_value_type_slots.py