stilt.execution.SimulationTask#
- class stilt.execution.SimulationTask(*, compute_root: pathlib.Path, sim_id: stilt.simulation.SimID, meteorology: stilt.meteorology.MetStream, receptor: stilt.receptors.Receptor, params: stilt.config.params.STILTParams, skip_existing: bool = False, foot_configs: dict[str, stilt.config.footprint.FootprintConfig] | None = None, storage: stilt.storage.project.Storage) None[source]#
Serialisable bundle of everything a worker needs to run one simulation.
Passed as the single argument to
execute_task()so it can be pickled and shipped to a remote executor (local subprocess, Slurm task, Kubernetes Job) without needing shared runtime objects. Atomic claim handling stays outside the task on claim-capable index backends.
Attributes#
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|