Execution

module crystallize.plugins.execution

Global Variables

• TYPE_CHECKING
• VALID_EXECUTOR_TYPES

---

class SerialExecution

Execute replicates one after another within the main process.

method SerialExecution.__init__

__init__(progress: 'bool' = False) → None

---

method SerialExecution.run_experiment_loop

run_experiment_loop(
    experiment: "'Experiment'",
    replicate_fn: 'Callable[[int], Any]'
) → List[Any]

---

class ParallelExecution

Run SYNC replicates concurrently using ThreadPoolExecutor or ProcessPoolExecutor.

method ParallelExecution.__init__

__init__(
    max_workers: 'Optional[int]' = None,
    executor_type: 'str' = 'thread',
    progress: 'bool' = False
) → None

---

method ParallelExecution.run_experiment_loop

run_experiment_loop(
    experiment: "'Experiment'",
    replicate_fn: 'Callable[[int], Any]'
) → List[Any]

---

class AsyncExecution

Run async replicates concurrently using asyncio.gather.

method AsyncExecution.__init__

__init__(progress: 'bool' = False) → None

---

method AsyncExecution.run_experiment_loop

run_experiment_loop(
    experiment: "'Experiment'",
    replicate_fn: 'Callable[[int], Any]'
) → List[Any]