astrobase/lcproc/checkplotproc.py
def cp_objectinfo_worker(task):
    '''This is a parallel worker for `parallel_update_cp_objectinfo`.

    Parameters
    ----------

    task : tuple
        - task[0] = checkplot pickle file
        - task[1] = kwargs

    Returns
    -------

    str
        The name of the checkplot file that was updated. None if the update
        fails for some reason.

    '''

    cpf, cpkwargs = task

    try:

        newcpf = update_checkplot_objectinfo(cpf, **cpkwargs)
        return newcpf

    except Exception as e:
        LOGEXCEPTION('failed to update objectinfo for %s' % cpf)
        return None
def cp_objectinfo_worker(task):
    '''This is a parallel worker for `parallel_update_cp_objectinfo`.

    Parameters
    ----------

    task : tuple
        - task[0] = checkplot pickle file
        - task[1] = kwargs

    Returns
    -------

    str
        The name of the checkplot file that was updated. None if the update
        fails for some reason.

    '''

    cpf, cpkwargs = task

    try:

        newcpf = update_checkplot_objectinfo(cpf, **cpkwargs)
        return newcpf

    except Exception as e:
        LOGEXCEPTION('failed to update objectinfo for %s' % cpf)
        return None
def cp_objectinfo_worker ( task ) : cpf , cpkwargs = task try : newcpf = update_checkplot_objectinfo ( cpf , * * cpkwargs ) return newcpf except Exception as e : LOGEXCEPTION ( 'failed to update objectinfo for %s' % cpf ) return None
This is a parallel worker for `parallel_update_cp_objectinfo`.

    Parameters
    ----------

    task : tuple
        - task[0] = checkplot pickle file
        - task[1] = kwargs

    Returns
    -------

    str
        The name of the checkplot file that was updated. None if the update
        fails for some reason.
This is a parallel worker for parallel_update_cp_objectinfo .