.gitignore
CLAUDE.md
LICENSE
README.md
pyproject.toml
.github/workflows/pages.yml
.github/workflows/tests.yml
assets/el.png
benchmarks/benchmark_comm.py
benchmarks/benchmark_latency.py
benchmarks/benchmark_pool.py
benchmarks/benchmark_uv.py
benchmarks/benchmark_zero_copy.py
benchmarks/latency_results.csv
benchmarks/utils.py
docs/mkdocs.yml
docs/docs/api-reference.md
docs/docs/architecture.md
docs/docs/cli.md
docs/docs/cluster-mode.md
docs/docs/configuration.md
docs/docs/contributing.md
docs/docs/custom-scheduling.md
docs/docs/examples.md
docs/docs/index.md
docs/docs/installation.md
docs/docs/quickstart.md
docs/docs/experimental/actors.md
docs/docs/experimental/inference.md
docs/docs/experimental/mcp.md
ensemble_launcher/__init__.py
ensemble_launcher/cli.py
ensemble_launcher/ensemble_launcher.py
ensemble_launcher/helper_functions.py
ensemble_launcher/loop.py
ensemble_launcher.egg-info/PKG-INFO
ensemble_launcher.egg-info/SOURCES.txt
ensemble_launcher.egg-info/dependency_links.txt
ensemble_launcher.egg-info/entry_points.txt
ensemble_launcher.egg-info/requires.txt
ensemble_launcher.egg-info/top_level.txt
ensemble_launcher/checkpointing/__init__.py
ensemble_launcher/checkpointing/checkpointer.py
ensemble_launcher/comm/__init__.py
ensemble_launcher/comm/async_base.py
ensemble_launcher/comm/async_zmq.py
ensemble_launcher/comm/base.py
ensemble_launcher/comm/dragon.py
ensemble_launcher/comm/hb.py
ensemble_launcher/comm/messages.py
ensemble_launcher/comm/mp.py
ensemble_launcher/comm/nodeinfo.py
ensemble_launcher/comm/zmq.py
ensemble_launcher/comm/pipe/__init__.py
ensemble_launcher/comm/pipe/async_connection.py
ensemble_launcher/comm/pipe/async_transport.py
ensemble_launcher/comm/pipe/mp_connection.py
ensemble_launcher/comm/pipe/mp_transport.py
ensemble_launcher/comm/pipe/registry.py
ensemble_launcher/comm/pipe/utils.py
ensemble_launcher/comm/queue/__init__.py
ensemble_launcher/comm/queue/protocol.py
ensemble_launcher/comm/queue/registry.py
ensemble_launcher/config/__init__.py
ensemble_launcher/config/config.py
ensemble_launcher/config/mpi_config.py
ensemble_launcher/ensemble/__init__.py
ensemble_launcher/ensemble/actor.py
ensemble_launcher/ensemble/actor_pool.py
ensemble_launcher/ensemble/ensemble.py
ensemble_launcher/executors/__init__.py
ensemble_launcher/executors/async_mp_executor.py
ensemble_launcher/executors/async_mpi_executor.py
ensemble_launcher/executors/async_mpi_pool_executor.py
ensemble_launcher/executors/base.py
ensemble_launcher/executors/dragon_executor.py
ensemble_launcher/executors/mp_executor.py
ensemble_launcher/executors/mpi_executor.py
ensemble_launcher/executors/mpi_pool.py
ensemble_launcher/executors/utils.py
ensemble_launcher/inference/__init__.py
ensemble_launcher/inference/configs.py
ensemble_launcher/inference/copy_model.py
ensemble_launcher/inference/openai_inference.py
ensemble_launcher/inference/start_vllm_server.sh
ensemble_launcher/inference/utils.py
ensemble_launcher/inference/vllm_inference.py
ensemble_launcher/logging/__init__.py
ensemble_launcher/mcp/__init__.py
ensemble_launcher/mcp/interface.py
ensemble_launcher/mcp/utils.py
ensemble_launcher/orchestrator/__init__.py
ensemble_launcher/orchestrator/async_master.py
ensemble_launcher/orchestrator/async_worker.py
ensemble_launcher/orchestrator/async_workstealing_master.py
ensemble_launcher/orchestrator/async_workstealing_worker.py
ensemble_launcher/orchestrator/cluster_client.py
ensemble_launcher/orchestrator/master.py
ensemble_launcher/orchestrator/node.py
ensemble_launcher/orchestrator/utils.py
ensemble_launcher/orchestrator/worker.py
ensemble_launcher/profiling/__init__.py
ensemble_launcher/profiling/event_registry.py
ensemble_launcher/profiling/merge_traces.py
ensemble_launcher/scheduler/__init__.py
ensemble_launcher/scheduler/async_scheduler.py
ensemble_launcher/scheduler/child_state.py
ensemble_launcher/scheduler/policy.py
ensemble_launcher/scheduler/scheduler.py
ensemble_launcher/scheduler/state.py
ensemble_launcher/scheduler/resource/__init__.py
ensemble_launcher/scheduler/resource/cluster.py
ensemble_launcher/scheduler/resource/node.py
ensemble_launcher/tests/conftest.py
ensemble_launcher/tests/ensembles.json
ensemble_launcher/tests/py_echo.py
ensemble_launcher/tests/start_mcp.py
ensemble_launcher/tests/test_actor.py
ensemble_launcher/tests/test_actor_pool.py
ensemble_launcher/tests/test_async_comm.py
ensemble_launcher/tests/test_async_executor.py
ensemble_launcher/tests/test_async_master.py
ensemble_launcher/tests/test_async_worker.py
ensemble_launcher/tests/test_async_workstealing_master.py
ensemble_launcher/tests/test_cluster.py
ensemble_launcher/tests/test_connections.py
ensemble_launcher/tests/test_el.py
ensemble_launcher/tests/test_ensemble_launcher.py
ensemble_launcher/tests/test_fault_tolerance.py
ensemble_launcher/tests/test_mcp.py
ensemble_launcher/tests/test_resource_manager.py
ensemble_launcher/tests/test_scheduler.py
ensemble_launcher/tests/test_ser_deser.py
ensemble_launcher/tests/test_vllm.py
ensemble_launcher/tests/time_execution.py
ensemble_launcher/tests/utils.py
examples/agents/pydantic/README.md
examples/agents/pydantic/agents.py
examples/agents/pydantic/joke_generator.py
examples/agents/pydantic/utils.py
examples/batch/mixed_workload.py
examples/batch/python_tasks.py
examples/batch/shell_tasks.py
examples/cluster/cluster_mode.py
examples/cluster/cluster_shell_tasks.py
examples/mcp/combustion/README.md
examples/mcp/combustion/flamespeed.py
examples/mcp/combustion/start_mcp_http.py
examples/python/mpi_example.py
examples/python/serial_example.py