CODE_OF_CONDUCT.md
CONTRIBUTING.md
LICENSE
MANIFEST.in
README-DOCS.md
README.md
SECURITY.md
basics.md
data_quality.md
decorators.md
developer_setup.md
requirements-test.txt
requirements.txt
setup.cfg
setup.py
hamilton/__init__.py
hamilton/ad_hoc_utils.py
hamilton/async_driver.py
hamilton/base.py
hamilton/driver.py
hamilton/function_modifiers_base.py
hamilton/graph.py
hamilton/graph_types.py
hamilton/graph_utils.py
hamilton/htypes.py
hamilton/log_setup.py
hamilton/models.py
hamilton/node.py
hamilton/registry.py
hamilton/settings.py
hamilton/telemetry.py
hamilton/version.py
hamilton/cli/__init__.py
hamilton/cli/__main__.py
hamilton/cli/commands.py
hamilton/cli/logic.py
hamilton/common/__init__.py
hamilton/contrib/__init__.py
hamilton/data_quality/__init__.py
hamilton/data_quality/base.py
hamilton/data_quality/default_validators.py
hamilton/data_quality/pandera_validators.py
hamilton/dataflows/__init__.py
hamilton/dataflows/template/__init__.py
hamilton/dev_utils/__init__.py
hamilton/dev_utils/deprecation.py
hamilton/execution/__init__.py
hamilton/execution/debugging_utils.py
hamilton/execution/executors.py
hamilton/execution/graph_functions.py
hamilton/execution/grouping.py
hamilton/execution/state.py
hamilton/experimental/__init__.py
hamilton/experimental/databackend.py
hamilton/experimental/h_async.py
hamilton/experimental/h_cache.py
hamilton/experimental/h_dask.py
hamilton/experimental/h_databackends.py
hamilton/experimental/h_quokka.py
hamilton/experimental/h_ray.py
hamilton/experimental/h_spark.py
hamilton/experimental/decorators/__init__.py
hamilton/experimental/decorators/parameterize_frame.py
hamilton/function_modifiers/__init__.py
hamilton/function_modifiers/adapters.py
hamilton/function_modifiers/base.py
hamilton/function_modifiers/configuration.py
hamilton/function_modifiers/delayed.py
hamilton/function_modifiers/dependencies.py
hamilton/function_modifiers/expanders.py
hamilton/function_modifiers/macros.py
hamilton/function_modifiers/metadata.py
hamilton/function_modifiers/recursive.py
hamilton/function_modifiers/validation.py
hamilton/io/__init__.py
hamilton/io/data_adapters.py
hamilton/io/default_data_loaders.py
hamilton/io/materialization.py
hamilton/io/utils.py
hamilton/lifecycle/__init__.py
hamilton/lifecycle/api.py
hamilton/lifecycle/base.py
hamilton/lifecycle/default.py
hamilton/plugins/__init__.py
hamilton/plugins/dask_extensions.py
hamilton/plugins/dlt_extensions.py
hamilton/plugins/geopandas_extensions.py
hamilton/plugins/h_dask.py
hamilton/plugins/h_ddog.py
hamilton/plugins/h_diskcache.py
hamilton/plugins/h_evidently.py
hamilton/plugins/h_kedro.py
hamilton/plugins/h_mlflow.py
hamilton/plugins/h_nannyml.py
hamilton/plugins/h_narwhals.py
hamilton/plugins/h_pandera.py
hamilton/plugins/h_polars.py
hamilton/plugins/h_polars_lazyframe.py
hamilton/plugins/h_pyarrow.py
hamilton/plugins/h_ray.py
hamilton/plugins/h_schema.py
hamilton/plugins/h_slack.py
hamilton/plugins/h_spark.py
hamilton/plugins/h_tqdm.py
hamilton/plugins/h_vaex.py
hamilton/plugins/huggingface_extensions.py
hamilton/plugins/ibis_extensions.py
hamilton/plugins/jupyter_magic.py
hamilton/plugins/kedro_extensions.py
hamilton/plugins/lightgbm_extensions.py
hamilton/plugins/matplotlib_extensions.py
hamilton/plugins/mlflow_extensions.py
hamilton/plugins/numpy_extensions.py
hamilton/plugins/pandas_extensions.py
hamilton/plugins/plotly_extensions.py
hamilton/plugins/polars_extensions.py
hamilton/plugins/polars_implementations.py
hamilton/plugins/polars_lazyframe_extensions.py
hamilton/plugins/polars_post_1_0_0_extensions.py
hamilton/plugins/polars_pre_1_0_0_extension.py
hamilton/plugins/pyspark_pandas_extensions.py
hamilton/plugins/sklearn_plot_extensions.py
hamilton/plugins/spark_extensions.py
hamilton/plugins/vaex_extensions.py
hamilton/plugins/xgboost_extensions.py
hamilton/plugins/yaml_extensions.py
hamilton/plugins/h_experiments/__init__.py
hamilton/plugins/h_experiments/__main__.py
hamilton/plugins/h_experiments/cache.py
hamilton/plugins/h_experiments/data_model.py
hamilton/plugins/h_experiments/hook.py
hamilton/plugins/h_experiments/server.py
plugin_tests/__init__.py
plugin_tests/h_dask/__init__.py
plugin_tests/h_dask/conftest.py
plugin_tests/h_dask/test_h_dask.py
plugin_tests/h_dask/resources/__init__.py
plugin_tests/h_dask/resources/bad_functions.py
plugin_tests/h_dask/resources/compatible_input_types.py
plugin_tests/h_dask/resources/config_modifier.py
plugin_tests/h_dask/resources/cyclic_functions.py
plugin_tests/h_dask/resources/data_quality.py
plugin_tests/h_dask/resources/dq_dummy_examples.py
plugin_tests/h_dask/resources/dummy_functions.py
plugin_tests/h_dask/resources/dynamic_config.py
plugin_tests/h_dask/resources/example_module.py
plugin_tests/h_dask/resources/extract_column_nodes.py
plugin_tests/h_dask/resources/extract_columns_execution_count.py
plugin_tests/h_dask/resources/functions_with_generics.py
plugin_tests/h_dask/resources/incompatible_input_types.py
plugin_tests/h_dask/resources/layered_decorators.py
plugin_tests/h_dask/resources/multiple_decorators_together.py
plugin_tests/h_dask/resources/only_import_me.py
plugin_tests/h_dask/resources/optional_dependencies.py
plugin_tests/h_dask/resources/overrides.py
plugin_tests/h_dask/resources/parametrized_inputs.py
plugin_tests/h_dask/resources/parametrized_nodes.py
plugin_tests/h_dask/resources/pipe.py
plugin_tests/h_dask/resources/reuse_subdag.py
plugin_tests/h_dask/resources/smoke_screen_module.py
plugin_tests/h_dask/resources/tagging.py
plugin_tests/h_dask/resources/test_default_args.py
plugin_tests/h_dask/resources/test_for_materialization.py
plugin_tests/h_dask/resources/typing_vs_not_typing.py
plugin_tests/h_dask/resources/very_simple_dag.py
plugin_tests/h_dask/resources/config/__init__.py
plugin_tests/h_dask/resources/config/default_config.py
plugin_tests/h_dask/resources/config/default_config_2.py
plugin_tests/h_dask/resources/config/user_specified_config.py
plugin_tests/h_dask/resources/dynamic_parallelism/__init__.py
plugin_tests/h_dask/resources/dynamic_parallelism/inputs_in_collect.py
plugin_tests/h_dask/resources/dynamic_parallelism/no_parallel.py
plugin_tests/h_dask/resources/dynamic_parallelism/parallel_collect_multiple_arguments.py
plugin_tests/h_dask/resources/dynamic_parallelism/parallel_complex.py
plugin_tests/h_dask/resources/dynamic_parallelism/parallel_delayed.py
plugin_tests/h_dask/resources/dynamic_parallelism/parallel_linear_basic.py
plugin_tests/h_dask/resources/spark/__init__.py
plugin_tests/h_dask/resources/spark/a_dag.py
plugin_tests/h_dask/resources/spark/basic_spark_dag.py
plugin_tests/h_dask/resources/spark/pyspark_udfs.py
plugin_tests/h_dask/resources/spark/spark_dag_external_dependencies.py
plugin_tests/h_dask/resources/spark/spark_dag_mixed_pyspark_pandas_udfs.py
plugin_tests/h_dask/resources/spark/spark_dag_multiple_with_columns.py
plugin_tests/h_dask/resources/spark/spark_dag_pyspark_udfs.py
plugin_tests/h_ray/__init__.py
plugin_tests/h_ray/conftest.py
plugin_tests/h_ray/test_h_ray.py
plugin_tests/h_ray/test_h_ray_workflow.py
plugin_tests/h_ray/test_parse_ray_remote_options_from_tags.py
plugin_tests/h_ray/resources/__init__.py
plugin_tests/h_ray/resources/bad_functions.py
plugin_tests/h_ray/resources/compatible_input_types.py
plugin_tests/h_ray/resources/config_modifier.py
plugin_tests/h_ray/resources/cyclic_functions.py
plugin_tests/h_ray/resources/data_quality.py
plugin_tests/h_ray/resources/dq_dummy_examples.py
plugin_tests/h_ray/resources/dummy_functions.py
plugin_tests/h_ray/resources/dynamic_config.py
plugin_tests/h_ray/resources/example_module.py
plugin_tests/h_ray/resources/extract_column_nodes.py
plugin_tests/h_ray/resources/extract_columns_execution_count.py
plugin_tests/h_ray/resources/functions_with_generics.py
plugin_tests/h_ray/resources/incompatible_input_types.py
plugin_tests/h_ray/resources/layered_decorators.py
plugin_tests/h_ray/resources/multiple_decorators_together.py
plugin_tests/h_ray/resources/only_import_me.py
plugin_tests/h_ray/resources/optional_dependencies.py
plugin_tests/h_ray/resources/overrides.py
plugin_tests/h_ray/resources/parametrized_inputs.py
plugin_tests/h_ray/resources/parametrized_nodes.py
plugin_tests/h_ray/resources/pipe.py
plugin_tests/h_ray/resources/reuse_subdag.py
plugin_tests/h_ray/resources/smoke_screen_module.py
plugin_tests/h_ray/resources/tagging.py
plugin_tests/h_ray/resources/test_default_args.py
plugin_tests/h_ray/resources/test_for_materialization.py
plugin_tests/h_ray/resources/typing_vs_not_typing.py
plugin_tests/h_ray/resources/very_simple_dag.py
plugin_tests/h_ray/resources/config/__init__.py
plugin_tests/h_ray/resources/config/default_config.py
plugin_tests/h_ray/resources/config/default_config_2.py
plugin_tests/h_ray/resources/config/user_specified_config.py
plugin_tests/h_ray/resources/dynamic_parallelism/__init__.py
plugin_tests/h_ray/resources/dynamic_parallelism/inputs_in_collect.py
plugin_tests/h_ray/resources/dynamic_parallelism/no_parallel.py
plugin_tests/h_ray/resources/dynamic_parallelism/parallel_collect_multiple_arguments.py
plugin_tests/h_ray/resources/dynamic_parallelism/parallel_complex.py
plugin_tests/h_ray/resources/dynamic_parallelism/parallel_delayed.py
plugin_tests/h_ray/resources/dynamic_parallelism/parallel_linear_basic.py
plugin_tests/h_ray/resources/spark/__init__.py
plugin_tests/h_ray/resources/spark/a_dag.py
plugin_tests/h_ray/resources/spark/basic_spark_dag.py
plugin_tests/h_ray/resources/spark/pyspark_udfs.py
plugin_tests/h_ray/resources/spark/spark_dag_external_dependencies.py
plugin_tests/h_ray/resources/spark/spark_dag_mixed_pyspark_pandas_udfs.py
plugin_tests/h_ray/resources/spark/spark_dag_multiple_with_columns.py
plugin_tests/h_ray/resources/spark/spark_dag_pyspark_udfs.py
plugin_tests/h_spark/__init__.py
plugin_tests/h_spark/conftest.py
plugin_tests/h_spark/test_h_spark.py
plugin_tests/h_spark/resources/__init__.py
plugin_tests/h_spark/resources/bad_functions.py
plugin_tests/h_spark/resources/compatible_input_types.py
plugin_tests/h_spark/resources/config_modifier.py
plugin_tests/h_spark/resources/cyclic_functions.py
plugin_tests/h_spark/resources/data_quality.py
plugin_tests/h_spark/resources/dq_dummy_examples.py
plugin_tests/h_spark/resources/dummy_functions.py
plugin_tests/h_spark/resources/dynamic_config.py
plugin_tests/h_spark/resources/example_module.py
plugin_tests/h_spark/resources/extract_column_nodes.py
plugin_tests/h_spark/resources/extract_columns_execution_count.py
plugin_tests/h_spark/resources/functions_with_generics.py
plugin_tests/h_spark/resources/incompatible_input_types.py
plugin_tests/h_spark/resources/layered_decorators.py
plugin_tests/h_spark/resources/multiple_decorators_together.py
plugin_tests/h_spark/resources/only_import_me.py
plugin_tests/h_spark/resources/optional_dependencies.py
plugin_tests/h_spark/resources/overrides.py
plugin_tests/h_spark/resources/parametrized_inputs.py
plugin_tests/h_spark/resources/parametrized_nodes.py
plugin_tests/h_spark/resources/pipe.py
plugin_tests/h_spark/resources/reuse_subdag.py
plugin_tests/h_spark/resources/smoke_screen_module.py
plugin_tests/h_spark/resources/tagging.py
plugin_tests/h_spark/resources/test_default_args.py
plugin_tests/h_spark/resources/test_for_materialization.py
plugin_tests/h_spark/resources/typing_vs_not_typing.py
plugin_tests/h_spark/resources/very_simple_dag.py
plugin_tests/h_spark/resources/config/__init__.py
plugin_tests/h_spark/resources/config/default_config.py
plugin_tests/h_spark/resources/config/default_config_2.py
plugin_tests/h_spark/resources/config/user_specified_config.py
plugin_tests/h_spark/resources/dynamic_parallelism/__init__.py
plugin_tests/h_spark/resources/dynamic_parallelism/inputs_in_collect.py
plugin_tests/h_spark/resources/dynamic_parallelism/no_parallel.py
plugin_tests/h_spark/resources/dynamic_parallelism/parallel_collect_multiple_arguments.py
plugin_tests/h_spark/resources/dynamic_parallelism/parallel_complex.py
plugin_tests/h_spark/resources/dynamic_parallelism/parallel_delayed.py
plugin_tests/h_spark/resources/dynamic_parallelism/parallel_linear_basic.py
plugin_tests/h_spark/resources/spark/__init__.py
plugin_tests/h_spark/resources/spark/a_dag.py
plugin_tests/h_spark/resources/spark/basic_spark_dag.py
plugin_tests/h_spark/resources/spark/pyspark_udfs.py
plugin_tests/h_spark/resources/spark/spark_dag_external_dependencies.py
plugin_tests/h_spark/resources/spark/spark_dag_mixed_pyspark_pandas_udfs.py
plugin_tests/h_spark/resources/spark/spark_dag_multiple_with_columns.py
plugin_tests/h_spark/resources/spark/spark_dag_pyspark_udfs.py
plugin_tests/h_vaex/__init__.py
plugin_tests/h_vaex/conftest.py
plugin_tests/h_vaex/test_h_vaex.py
plugin_tests/h_vaex/resources/__init__.py
plugin_tests/h_vaex/resources/functions.py
sf_hamilton.egg-info/PKG-INFO
sf_hamilton.egg-info/SOURCES.txt
sf_hamilton.egg-info/dependency_links.txt
sf_hamilton.egg-info/entry_points.txt
sf_hamilton.egg-info/not-zip-safe
sf_hamilton.egg-info/requires.txt
sf_hamilton.egg-info/top_level.txt
tests/test_ad_hoc_utils.py
tests/test_async_driver.py
tests/test_base.py
tests/test_caching.py
tests/test_common.py
tests/test_default_data_quality.py
tests/test_dev_utils.py
tests/test_driver_export.py
tests/test_end_to_end.py
tests/test_function_modifiers.py
tests/test_graph.py
tests/test_graph_types.py
tests/test_hamilton_driver.py
tests/test_node.py
tests/test_parallel_graceful.py
tests/test_settings.py
tests/test_telemetry.py
tests/test_type_utils.py
tests/cli/__init__.py
tests/cli/test_cli.py
tests/cli/test_logic.py
tests/cli/resources/__init__.py
tests/cli/resources/module_v1.py
tests/cli/resources/module_v2.py
tests/execution/__init__.py
tests/execution/test_executors.py
tests/execution/test_graph_functions.py
tests/execution/test_node_grouping.py
tests/function_modifiers/__init__.py
tests/function_modifiers/test_adapters.py
tests/function_modifiers/test_base.py
tests/function_modifiers/test_combined.py
tests/function_modifiers/test_configuration.py
tests/function_modifiers/test_delayed.py
tests/function_modifiers/test_dependencies.py
tests/function_modifiers/test_expanders.py
tests/function_modifiers/test_macros.py
tests/function_modifiers/test_metadata.py
tests/function_modifiers/test_recursive.py
tests/function_modifiers/test_validation.py
tests/lifecycle/__init__.py
tests/lifecycle/lifecycle_adapters_for_testing.py
tests/lifecycle/test_cache_adapter.py
tests/lifecycle/test_lifecycle_adapters_end_to_end.py
tests/lifecycle/test_lifecycle_adapters_end_to_end_task_based.py
tests/lifecycle/test_lifecycle_base.py
tests/plugins/__init__.py
tests/plugins/test_dlt_extensions.py
tests/plugins/test_h_diskcache.py
tests/plugins/test_h_kedro.py
tests/plugins/test_h_pyarrow.py
tests/plugins/test_huggingface_extensions.py
tests/plugins/test_kedro_extensions.py
tests/plugins/test_lightgbm_extensions.py
tests/plugins/test_matplotlib_extensions.py
tests/plugins/test_numpy_extensions.py
tests/plugins/test_pandas_extensions.py
tests/plugins/test_plotly_extensions.py
tests/plugins/test_polars_extensions.py
tests/plugins/test_polars_lazyframe_extensions.py
tests/plugins/test_sklearn_plot_extensions.py
tests/plugins/test_xgboost_extensions.py
tests/plugins/test_yaml_extension.py
tests/resources/__init__.py
tests/resources/bad_functions.py
tests/resources/compatible_input_types.py
tests/resources/config_modifier.py
tests/resources/cyclic_functions.py
tests/resources/data_quality.py
tests/resources/dq_dummy_examples.py
tests/resources/dummy_functions.py
tests/resources/dynamic_config.py
tests/resources/example_module.py
tests/resources/extract_column_nodes.py
tests/resources/extract_columns_execution_count.py
tests/resources/functions_with_generics.py
tests/resources/incompatible_input_types.py
tests/resources/layered_decorators.py
tests/resources/multiple_decorators_together.py
tests/resources/only_import_me.py
tests/resources/optional_dependencies.py
tests/resources/overrides.py
tests/resources/parametrized_inputs.py
tests/resources/parametrized_nodes.py
tests/resources/pipe.py
tests/resources/reuse_subdag.py
tests/resources/smoke_screen_module.py
tests/resources/tagging.py
tests/resources/test_default_args.py
tests/resources/test_for_materialization.py
tests/resources/typing_vs_not_typing.py
tests/resources/very_simple_dag.py
tests/resources/config/__init__.py
tests/resources/config/default_config.py
tests/resources/config/default_config_2.py
tests/resources/config/user_specified_config.py
tests/resources/dynamic_parallelism/__init__.py
tests/resources/dynamic_parallelism/inputs_in_collect.py
tests/resources/dynamic_parallelism/no_parallel.py
tests/resources/dynamic_parallelism/parallel_collect_multiple_arguments.py
tests/resources/dynamic_parallelism/parallel_complex.py
tests/resources/dynamic_parallelism/parallel_delayed.py
tests/resources/dynamic_parallelism/parallel_linear_basic.py
tests/resources/spark/__init__.py
tests/resources/spark/a_dag.py
tests/resources/spark/basic_spark_dag.py
tests/resources/spark/pyspark_udfs.py
tests/resources/spark/spark_dag_external_dependencies.py
tests/resources/spark/spark_dag_mixed_pyspark_pandas_udfs.py
tests/resources/spark/spark_dag_multiple_with_columns.py
tests/resources/spark/spark_dag_pyspark_udfs.py