.gitignore
AGENTS.md
LICENSE
MANIFEST.in
README.md
pyproject.toml
zensical.toml
.github/workflows/docs.yml
.github/workflows/publish.yml
examples/README.md
examples/query_project_rows.py
examples/run_to_table.py
examples/workers.py
src/ms_flow/__init__.py
src/ms_flow/advanced.py
src/ms_flow/api.py
src/ms_flow/artifacts.py
src/ms_flow/campaign.py
src/ms_flow/locations.py
src/ms_flow/logger.py
src/ms_flow/main.py
src/ms_flow/payloads.py
src/ms_flow/progress.py
src/ms_flow/query.py
src/ms_flow/ray_hosts.py
src/ms_flow/remote.py
src/ms_flow/runner.py
src/ms_flow/runtime.py
src/ms_flow/selection.py
src/ms_flow/sinks.py
src/ms_flow/site_script.py
src/ms_flow.egg-info/PKG-INFO
src/ms_flow.egg-info/SOURCES.txt
src/ms_flow.egg-info/dependency_links.txt
src/ms_flow.egg-info/requires.txt
src/ms_flow.egg-info/scm_file_list.json
src/ms_flow.egg-info/scm_version.json
src/ms_flow.egg-info/top_level.txt
src/ms_flow/_api_impl/__init__.py
src/ms_flow/_api_impl/advanced.py
src/ms_flow/_api_impl/job_api.py
src/ms_flow/_api_impl/project_runtime.py
src/ms_flow/core/__init__.py
src/ms_flow/core/app_settings.py
src/ms_flow/core/apps.py
src/ms_flow/core/configuration.py
src/ms_flow/core/events.py
src/ms_flow/core/data/__init__.py
src/ms_flow/core/data/backends.py
src/ms_flow/core/data/bridge.py
src/ms_flow/core/data/contracts.py
src/ms_flow/core/data/planner.py
src/ms_flow/core/data/project_output.py
src/ms_flow/core/data/runtime.py
src/ms_flow/core/data/shard.py
src/ms_flow/core/database/__init__.py
src/ms_flow/core/database/base.py
src/ms_flow/core/database/master.py
src/ms_flow/core/database/master_models.py
src/ms_flow/core/database/project.py
src/ms_flow/core/database/project_models.py
src/ms_flow/core/database/project_records.py
src/ms_flow/core/database/project_store_ops.py
src/ms_flow/core/database/sqlite_utils.py
src/ms_flow/core/project/__init__.py
src/ms_flow/core/project/catalog.py
src/ms_flow/core/project/context.py
src/ms_flow/core/project/manager.py
src/ms_flow/core/project/repository.py
src/ms_flow/core/project/resources.py
src/ms_flow/core/project/state.py
src/ms_flow/core/settings/__init__.py
src/ms_flow/core/settings/defaults.toml
src/ms_flow/core/settings/manager.py
src/ms_flow/core/settings/models.py
src/ms_flow/engine/__init__.py
src/ms_flow/engine/engine.py
src/ms_flow/engine/executors.py
src/ms_flow/engine/files.py
src/ms_flow/engine/flow.py
src/ms_flow/engine/journal.py
src/ms_flow/engine/tokens.py
src/ms_flow/specs/__init__.py
src/ms_flow/specs/input.py
src/ms_flow/specs/output.py
tests/conftest.py
tests/lab_tasks.py
tests/test_app_registry.py
tests/test_artifact_registry.py
tests/test_bench_volumes.py
tests/test_campaign.py
tests/test_data_api.py
tests/test_data_backend.py
tests/test_database_manager.py
tests/test_database_migrations.py
tests/test_db_pages.py
tests/test_engine_core.py
tests/test_engine_flow.py
tests/test_engine_journal.py
tests/test_file_sink_append.py
tests/test_files.py
tests/test_graph_deferred_relation.py
tests/test_hosts_executors.py
tests/test_lab.py
tests/test_logging_manager.py
tests/test_outlives.py
tests/test_output_helpers.py
tests/test_payloads.py
tests/test_payloads_codecs.py
tests/test_payloads_groups.py
tests/test_payloads_jobs.py
tests/test_payloads_maintenance.py
tests/test_payloads_read.py
tests/test_project_catalog.py
tests/test_project_manager.py
tests/test_project_storage.py
tests/test_project_store.py
tests/test_prune_missing_projects.py
tests/test_public_api.py
tests/test_pydantic_configuration.py
tests/test_query_column_types.py
tests/test_remote.py
tests/test_runner.py
tests/test_selection.py
tests/test_settings_manager.py
tests/test_shard_container.py
tests/test_sink_column_defaults.py
tests/test_sink_computed_column.py
tests/test_sink_upsert_keys.py
tests/test_sql_compiler.py
tests/test_task_chain.py
tests/test_transport_planning.py
tests/test_workspace_runtime.py