salvus.project.configuration.processing

class ProcessingConfiguration(
    salvus.flow.utils.serialization_helpers.SerializationMixin
):
    def __init__(
        self,
        name: str,
        data_source_name: str,
        processing_function: Union[str, Callable],
    ):
        ...

Define processing within SalvusProject with a function. Any function with a suitable signature is acceptable.

The function must take the following arguments:

• st: An obspy.Stream object with the data.
• receiver: The receiver object for the receiver.
• sources: All sources for the event.

In the case of seismological data it can also optionally take:

• inv: An obspy.Inventory object for the station in case it is stored in an ASDF file. Might be None.

The function must return the processed obspy.Stream object which must contain exactly the same number of traces.

def from_json(d: Dict) -> Any:
    ...

def to_json(self) -> Dict:
    ...