.bandit
.flake8
.gitignore
.readthedocs.yml
CHANGELOG.rst
CONTRIBUTING.rst
Jenkinsfile
LICENSE
Makefile
README.rst
pyproject.toml
python_versions.json
pytype.cfg
setup.py
update_readme.py
.github/CODEOWNERS
.github/pull_request_template.md
.github/workflows/deploy.yml
.github/workflows/update_readme.yml
docs/Makefile
docs/nitpick-exceptions
docs/source/conf.py
docs/source/glossary.rst
docs/source/index.rst
docs/source/_static/style.css
docs/source/_templates/layout.html
docs/source/api_reference/cli.rst
docs/source/api_reference/configuration.rst
docs/source/api_reference/graph_components.rst
docs/source/api_reference/implementation.rst
docs/source/api_reference/index.rst
docs/source/api_reference/pipeline.rst
docs/source/api_reference/pipeline_graph.rst
docs/source/api_reference/pipeline_schema.rst
docs/source/api_reference/rule.rst
docs/source/api_reference/runner.rst
docs/source/api_reference/step.rst
docs/source/api_reference/pipeline_schema_constants/development.rst
docs/source/api_reference/pipeline_schema_constants/index.rst
docs/source/api_reference/pipeline_schema_constants/testing.rst
docs/source/api_reference/utilities/aggregator_utils.rst
docs/source/api_reference/utilities/data_utils.rst
docs/source/api_reference/utilities/general_utils.rst
docs/source/api_reference/utilities/index.rst
docs/source/api_reference/utilities/paths.rst
docs/source/api_reference/utilities/splitter_utils.rst
docs/source/api_reference/utilities/validation_utils.rst
docs/source/concepts/index.rst
docs/source/concepts/workarounds.rst
docs/source/concepts/pipeline_schema/index.rst
docs/source/concepts/pipeline_schema/images/01_step.drawio.png
docs/source/concepts/pipeline_schema/images/02_default_implementation.drawio.png
docs/source/concepts/pipeline_schema/images/03_slots.drawio.png
docs/source/concepts/pipeline_schema/images/04_data_dependency.drawio.png
docs/source/concepts/pipeline_schema/images/05_pipeline_schema.drawio.png
docs/source/concepts/pipeline_schema/images/06_default_input.drawio.png
docs/source/concepts/pipeline_schema/images/07_cloneable_section.drawio.png
docs/source/concepts/pipeline_schema/images/08_cloneable_section_expanded.drawio.png
docs/source/concepts/pipeline_schema/images/09_loopable_section.drawio.png
docs/source/concepts/pipeline_schema/images/10_loopable_section_expanded.drawio.png
docs/source/concepts/pipeline_schema/images/11_cloneable_section_splitter.drawio.png
docs/source/concepts/pipeline_schema/images/12_cloneable_section_splitter_expanded.drawio.png
docs/source/concepts/pipeline_schema/images/13_autoparallel_section.drawio.png
docs/source/concepts/pipeline_schema/images/14_choice_section.drawio.png
docs/source/concepts/pipeline_schema/images/15_choice_section_expanded.drawio.png
docs/source/concepts/pipeline_schema/images/16_step_hierarchy.drawio.png
docs/source/concepts/pipeline_schema/images/18_schema_to_pipeline.drawio.png
docs/source/concepts/pipeline_schema/images/19_schema_to_pipeline_combined.drawio.png
docs/source/concepts/pipeline_schema/images/clustering_sub_steps.drawio.png
docs/source/concepts/pipeline_schema/images/easylink_pipeline_schema.drawio.png
docs/source/concepts/pipeline_schema/images/entity_resolution_sub_steps.drawio.png
docs/source/concepts/pipeline_schema/images/linking_sub_steps.drawio.png
docs/source/user_guide/cli.rst
docs/source/user_guide/index.rst
docs/source/user_guide/tutorials/DAG-common-pipeline.svg
docs/source/user_guide/tutorials/DAG-e2e-pipeline-expanded.svg
docs/source/user_guide/tutorials/DAG-e2e-pipeline.svg
docs/source/user_guide/tutorials/DAG-r-pyspark.svg
docs/source/user_guide/tutorials/environment_slurm.yaml
docs/source/user_guide/tutorials/getting_started.rst
docs/source/user_guide/tutorials/impl-config-pipeline.yaml
docs/source/user_guide/tutorials/index.rst
docs/source/user_guide/tutorials/input_data.yaml
docs/source/user_guide/tutorials/input_file_1.parquet
docs/source/user_guide/tutorials/input_file_2.parquet
docs/source/user_guide/tutorials/input_file_3.parquet
docs/source/user_guide/tutorials/r_spark_pipeline.yaml
src/easylink/__about__.py
src/easylink/__init__.py
src/easylink/_version.py
src/easylink/cli.py
src/easylink/configuration.py
src/easylink/graph_components.py
src/easylink/implementation.py
src/easylink/implementation_metadata.yaml
src/easylink/pipeline.py
src/easylink/pipeline_graph.py
src/easylink/pipeline_schema.py
src/easylink/rule.py
src/easylink/runner.py
src/easylink/step.py
src/easylink.egg-info/PKG-INFO
src/easylink.egg-info/SOURCES.txt
src/easylink.egg-info/dependency_links.txt
src/easylink.egg-info/entry_points.txt
src/easylink.egg-info/not-zip-safe
src/easylink.egg-info/requires.txt
src/easylink.egg-info/top_level.txt
src/easylink/devtools/implementation_creator.py
src/easylink/images/spark_cluster/Dockerfile
src/easylink/images/spark_cluster/README.md
src/easylink/pipeline_schema_constants/__init__.py
src/easylink/pipeline_schema_constants/development.py
src/easylink/pipeline_schema_constants/main.py
src/easylink/pipeline_schema_constants/testing.py
src/easylink/steps/cascading/exclude_clustered.def
src/easylink/steps/cascading/exclude_clustered.py
src/easylink/steps/cascading/exclude_none.def
src/easylink/steps/cascading/exclude_none.py
src/easylink/steps/cascading/update_clusters_by_connected_components.def
src/easylink/steps/cascading/update_clusters_by_connected_components.py
src/easylink/steps/default/default_clusters_to_links.def
src/easylink/steps/default/default_clusters_to_links.py
src/easylink/steps/default/default_determining_exclusions.def
src/easylink/steps/default/default_determining_exclusions.py
src/easylink/steps/default/default_removing_records.def
src/easylink/steps/default/default_removing_records.py
src/easylink/steps/default/default_schema_alignment.def
src/easylink/steps/default/default_schema_alignment.py
src/easylink/steps/default/default_updating_clusters.def
src/easylink/steps/default/default_updating_clusters.py
src/easylink/steps/dev/README.md
src/easylink/steps/dev/build-containers-local.sh
src/easylink/steps/dev/build-containers-remote.sh
src/easylink/steps/dev/test.py
src/easylink/steps/dev/input_data/create_input_files.ipynb
src/easylink/steps/dev/input_data/input_file_1.csv
src/easylink/steps/dev/input_data/input_file_1.parquet
src/easylink/steps/dev/input_data/input_file_2.csv
src/easylink/steps/dev/input_data/input_file_2.parquet
src/easylink/steps/dev/python_pandas/README.md
src/easylink/steps/dev/python_pandas/dummy_step.py
src/easylink/steps/dev/python_pandas/python_pandas.def
src/easylink/steps/dev/python_pyspark/README.md
src/easylink/steps/dev/python_pyspark/dummy_step.py
src/easylink/steps/dev/python_pyspark/python_pyspark.def
src/easylink/steps/dev/r/README.md
src/easylink/steps/dev/r/dummy_step.R
src/easylink/steps/dev/r/r-image.def
src/easylink/steps/fastLink/fastLink_evaluating_pairs.R
src/easylink/steps/fastLink/fastLink_evaluating_pairs.def
src/easylink/steps/fastLink/fastLink_links_to_clusters.R
src/easylink/steps/fastLink/fastLink_links_to_clusters.def
src/easylink/steps/output_dir/dummy_step_1_for_output_dir_example.def
src/easylink/steps/output_dir/dummy_step_1_for_output_dir_example.py
src/easylink/steps/output_dir/dummy_step_2_for_output_dir_example.def
src/easylink/steps/output_dir/dummy_step_2_for_output_dir_example.py
src/easylink/steps/rl-dummy/canonicalizing_and_downstream_analysis/dummy_canonicalizing_and_downstream_analysis.def
src/easylink/steps/rl-dummy/canonicalizing_and_downstream_analysis/dummy_canonicalizing_and_downstream_analysis.py
src/easylink/steps/rl-dummy/input_data/create_input_files.ipynb
src/easylink/steps/rl-dummy/input_data/input_file_1.parquet
src/easylink/steps/rl-dummy/input_data/input_file_2.parquet
src/easylink/steps/rl-dummy/input_data/known_clusters.parquet
src/easylink/steps/rl-dummy/pre-processing/dummy_pre-processing.def
src/easylink/steps/rl-dummy/pre-processing/dummy_pre-processing.py
src/easylink/steps/splink/splink_blocking_and_filtering.def
src/easylink/steps/splink/splink_blocking_and_filtering.py
src/easylink/steps/splink/splink_evaluating_pairs.def
src/easylink/steps/splink/splink_evaluating_pairs.py
src/easylink/steps/splink/splink_links_to_clusters.def
src/easylink/steps/splink/splink_links_to_clusters.py
src/easylink/utilities/__init__.py
src/easylink/utilities/aggregator_utils.py
src/easylink/utilities/data_utils.py
src/easylink/utilities/general_utils.py
src/easylink/utilities/paths.py
src/easylink/utilities/spark.smk
src/easylink/utilities/splitter_utils.py
src/easylink/utilities/validation_utils.py
tests/__init__.py
tests/conftest.py
tests/e2e/pipeline_splink_dummy_results.csv
tests/e2e/test_easylink_run.py
tests/e2e/test_pipelines_main_schema.py
tests/e2e/test_step_types.py
tests/integration/test_compositions.py
tests/integration/test_data_utils.py
tests/integration/test_snakemake.py
tests/integration/test_snakemake_slurm.py
tests/integration/test_snakemake_spark.py
tests/specifications/common/environment_local.yaml
tests/specifications/common/input_data.yaml
tests/specifications/common/input_data_one_file.yaml
tests/specifications/common/pipeline.yaml
tests/specifications/e2e/environment_slurm.yaml
tests/specifications/e2e/input_data_dummy.yaml
tests/specifications/e2e/pipeline.yaml
tests/specifications/e2e/pipeline_cascade.yaml
tests/specifications/e2e/pipeline_expanded.yaml
tests/specifications/e2e/pipeline_splink_dummy.yaml
tests/specifications/e2e/pipeline_with_fastLink.yaml
tests/specifications/integration/environment_spark_slurm.yaml
tests/specifications/integration/pipeline.yaml
tests/specifications/integration/pipeline_output_dir.yaml
tests/specifications/integration/pipeline_output_dir_default.yaml
tests/specifications/integration/pipeline_spark.yaml
tests/specifications/integration/auto_parallel/pipeline_cloneable_step.yaml
tests/specifications/integration/auto_parallel/pipeline_hierarchical_step.yaml
tests/specifications/integration/auto_parallel/pipeline_loop_step.yaml
tests/specifications/unit/environment_minimum.yaml
tests/specifications/unit/environment_spark_slurm.yaml
tests/specifications/unit/pipeline.yaml
tests/specifications/unit/pipeline_bad_combined_implementations.yaml
tests/specifications/unit/pipeline_bad_implementation.yaml
tests/specifications/unit/pipeline_bad_loop_formatting.yaml
tests/specifications/unit/pipeline_bad_step.yaml
tests/specifications/unit/pipeline_bad_type_key.yaml
tests/specifications/unit/pipeline_combine_bad_implementation_names.yaml
tests/specifications/unit/pipeline_combine_bad_topology.yaml
tests/specifications/unit/pipeline_combine_two_steps.yaml
tests/specifications/unit/pipeline_combine_with_extra_node.yaml
tests/specifications/unit/pipeline_combine_with_iteration.yaml
tests/specifications/unit/pipeline_combine_with_iteration_cycle.yaml
tests/specifications/unit/pipeline_combine_with_missing_node.yaml
tests/specifications/unit/pipeline_combine_with_parallel.yaml
tests/specifications/unit/pipeline_missing_implementation_name.yaml
tests/specifications/unit/pipeline_missing_implementations.yaml
tests/specifications/unit/pipeline_missing_loop_nodes.yaml
tests/specifications/unit/pipeline_missing_step.yaml
tests/specifications/unit/pipeline_missing_substeps.yaml
tests/specifications/unit/pipeline_missing_type_key.yaml
tests/specifications/unit/pipeline_nested_templated_steps.yaml
tests/specifications/unit/pipeline_out_of_order.yaml
tests/specifications/unit/pipeline_spark.yaml
tests/specifications/unit/pipeline_type_config_mismatch.yaml
tests/specifications/unit/pipeline_wrong_clone_keys.yaml
tests/unit/__init__.py
tests/unit/conftest.py
tests/unit/test_cli.py
tests/unit/test_config.py
tests/unit/test_data_utils.py
tests/unit/test_general_utils.py
tests/unit/test_graph_components.py
tests/unit/test_implementation.py
tests/unit/test_implementation_creator.py
tests/unit/test_pipeline.py
tests/unit/test_pipeline_graph.py
tests/unit/test_pipeline_schema.py
tests/unit/test_rule.py
tests/unit/test_runner.py
tests/unit/test_step.py
tests/unit/test_validations.py
tests/unit/recipe_strings/python_pandas.txt
tests/unit/rule_strings/aggregation_rule.txt
tests/unit/rule_strings/auto_parallel_rule.txt
tests/unit/rule_strings/checkpoint_rule.txt
tests/unit/rule_strings/implemented_rule_local.txt
tests/unit/rule_strings/implemented_rule_slurm.txt
tests/unit/rule_strings/pipeline_local.txt
tests/unit/rule_strings/pipeline_slurm.txt
tests/unit/rule_strings/target_rule.txt
tests/unit/rule_strings/validation_rule.txt