salvus.project.tools.task_chains.compute_misfits_and_gradients.detail

def create_result_folders_on_all_sites(
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ]
) -> List[pathlib.Path]:
    ...

All the results from a task chain have to go somewhere - for now this will just be a folder in the run directory which we’ll create for each site. There is an assumption in that they share a file system - so we can later on collect the results from these folders.

def extract_from_project(
    p: salvus.project.project.Project,
    simulation_configuration: str,
    misfit_configuration: str,
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ],
    wavefield_compression: Optional[
        salvus.flow.collections.wavefield_compression.WavefieldCompression
    ],
) -> (
    salvus.project.tools.task_chains.compute_misfits_and_gradients.detail.ProjectData
):
    ...

Extract all the necessary pieces from an existing Salvus project.

def extract_simulation_template(
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ],
    project: salvus.project.project.Project,
    simulation_configuration: str,
    wavefield_compression: Optional[
        salvus.flow.collections.wavefield_compression.WavefieldCompression
    ],
) -> salvus.flow.simple_config.simulation.waveform.Waveform:
    ...

Gets a simulation template from a project and modifies it two-fold:

1. Convert the mesh paths to absolute paths - this will then work on the remote system under the assumption of a shared file system.
2. Create them as promise files so the paths will not be checked by flow which should speed up the process.

def generate_adjoint_input_file_from_forward_input_files(
    mesh: salvus.mesh.unstructured_mesh.UnstructuredMesh,
    w_forward: salvus.flow.simple_config.simulation.waveform.Waveform,
) -> salvus.flow.simple_config.simulation.waveform.Waveform:
    ...

Generate a generic adjoint input file from a forward simulation objects.

def get_memory_per_rank(
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ]
) -> Optional[float]:
    ...

Parse the memory per rank from a site configuration dict.

def get_use_cuda_gpus(
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ]
) -> bool:
    ...

CUDA flags from a site configuration dict.

def perform_sanity_checks(
    sites: Dict[
        str,
        salvus.flow.sites.task_chain.task_chain_site_config.TaskChainSiteConfig,
    ]
) -> None:
    ...

Perform a range of sanity checks.

class ProjectData(builtins.object):
    def __init__(
        self,
        simulation_configuration: salvus.project.configuration.simulation_configuration.SimulationConfiguration,
        simulation_template: salvus.flow.simple_config.simulation.waveform.Waveform,
        mesh: salvus.mesh.unstructured_mesh.UnstructuredMesh,
        mesh_filename: pathlib.Path,
        misfit_configuration: salvus.project.configuration.misfit_configuration.MisfitConfiguration,
        processing_configuration: salvus.project.configuration.processing.ProcessingConfiguration,
        data_selection_configuration: Optional[
            salvus.project.configuration.data_selection_configuration.DataSelectionConfiguration
        ],
        event_block_filename: pathlib.Path,
        data_proxy_filename: pathlib.Path,
    ) -> None:
        ...

A container collection information from project.