.gitignore
LICENSE
README.md
pyproject.toml
zensical.toml
.github/workflows/docs.yml
.github/workflows/publish.yml
docs/api_guide.md
docs/api_reference.md
docs/examples.md
docs/index.md
src/ms_flow/__init__.py
src/ms_flow/advanced.py
src/ms_flow/api.py
src/ms_flow/artifacts.py
src/ms_flow/job_templates.py
src/ms_flow/logger.py
src/ms_flow/main.py
src/ms_flow/progress.py
src/ms_flow/query.py
src/ms_flow/runtime.py
src/ms_flow/selection.py
src/ms_flow/sinks.py
src/ms_flow/tasking.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/callable_refs.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/executor.py
src/ms_flow/core/database/executor_models.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/executor/__init__.py
src/ms_flow/core/executor/backend_selector.py
src/ms_flow/core/executor/command_inbox.py
src/ms_flow/core/executor/dispatch_model.py
src/ms_flow/core/executor/dispatch_service.py
src/ms_flow/core/executor/executor_registry.py
src/ms_flow/core/executor/hpc_adapter.py
src/ms_flow/core/executor/hpc_runtime.py
src/ms_flow/core/executor/job_monitoring.py
src/ms_flow/core/executor/job_snapshot.py
src/ms_flow/core/executor/lifecycle_controller.py
src/ms_flow/core/executor/local_adapters.py
src/ms_flow/core/executor/local_compute_scheduler.py
src/ms_flow/core/executor/local_scheduler.py
src/ms_flow/core/executor/provisioning.py
src/ms_flow/core/executor/ray_adapter.py
src/ms_flow/core/executor/resource_manager.py
src/ms_flow/core/executor/result_handlers.py
src/ms_flow/core/executor/runner_refs.py
src/ms_flow/core/executor/runtime_state.py
src/ms_flow/core/executor/runtime_status_service.py
src/ms_flow/core/executor/staging_manager.py
src/ms_flow/core/executor/submission_service.py
src/ms_flow/core/executor/utils.py
src/ms_flow/core/executor/manager/__init__.py
src/ms_flow/core/executor/manager/_manager.py
src/ms_flow/core/executor/services/__init__.py
src/ms_flow/core/executor/services/dispatch_pool.py
src/ms_flow/core/executor/services/event_recorder.py
src/ms_flow/core/executor/services/feeding.py
src/ms_flow/core/executor/services/job_commands.py
src/ms_flow/core/executor/services/job_status.py
src/ms_flow/core/executor/services/job_store.py
src/ms_flow/core/executor/services/payload_store.py
src/ms_flow/core/executor/services/persistence_coordinator.py
src/ms_flow/core/executor/services/sink_writer_pool.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/specs/__init__.py
src/ms_flow/specs/input.py
src/ms_flow/specs/output.py
src/ms_flow/specs/processor.py
src/ms_flow/specs/workflow.py
tests/adapter_contracts.py
tests/adapter_test_fakes.py
tests/adversarial_runtime_scenarios.py
tests/conftest.py
tests/test_app_registry.py
tests/test_artifact_registry.py
tests/test_backend_selector.py
tests/test_batched_overhead_benchmark.py
tests/test_benchmark.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_deferred_chunk_resources.py
tests/test_dispatch_model.py
tests/test_executor_adapter_contracts.py
tests/test_executor_adapter_contracts_remote.py
tests/test_executor_manager.py
tests/test_executor_retention.py
tests/test_file_sink_append.py
tests/test_gpu_token_semaphore.py
tests/test_graph_deferred_relation.py
tests/test_hpc_io_threads.py
tests/test_hpc_reattach.py
tests/test_job_templates.py
tests/test_jobspec_api.py
tests/test_local_compute_scheduler.py
tests/test_local_scheduler.py
tests/test_logging_manager.py
tests/test_molsuite_runtime.py
tests/test_mrf070_runtime_overhead_benchmark.py
tests/test_mrf072_monitor_stability.py
tests/test_operational_store.py
tests/test_output_helpers.py
tests/test_output_sink_batching.py
tests/test_overhead_benchmark.py
tests/test_process_executor_benchmark.py
tests/test_progress.py
tests/test_project_catalog.py
tests/test_project_manager.py
tests/test_project_storage.py
tests/test_project_store.py
tests/test_provisioning.py
tests/test_public_api.py
tests/test_pydantic_configuration.py
tests/test_remote_e2e_optional.py
tests/test_resource_manager.py
tests/test_selection.py
tests/test_settings_manager.py
tests/test_shard_container.py
tests/test_simple_api.py
tests/test_sink_column_defaults.py
tests/test_sink_writer_pool.py
tests/test_sql_compiler.py
tests/test_staging_manager.py
tests/test_tasking_api.py
tests/test_workflow_api.py