Source code for pycif.plugins.models.lagrangian.io.outputs2native_adj

import copy

from .....utils.datastores.empty import init_empty




def outputs2native_adj(
        self, data2dump, input_type,
        di, df, runsubdir, mode='fwd',
        dump=True, onlyinit=False, do_simu=True,
        check_transforms=False, **kwargs):
    """Reads outputs to pycif objects.
       
       Does nothing for now as we instead read FLEXPART output 
       inside loop over observations in obsoper.py 

    """
    
    ddi = min(di, df)

    # Otherwise, crop the datastore to active species
    if not hasattr(self, "dataobs"):
        self.dataobs = {ddi: {spec: init_empty()
                        for spec in self.chemistry.acspecies.attributes}}
    
    if self.reset_obs[ddi]:
        self.dataobs[ddi] = {
            spec: init_empty()
            for spec in self.chemistry.acspecies.attributes}
        
    for trid in data2dump:
        mod_input = trid[0]
        trcr = trid[1]

        if mod_input != "concs":
            continue
        
        self.dataobs[ddi][trcr] = copy.deepcopy(data2dump[trid][ddi])
        self.reset_obs[ddi] = False