deprecated_code/workflows/mpi/imaging/imaging_mpi.py
def deconvolve_list_mpi_workflow(dirty_list, psf_list, model_imagelist,
                                        prefix='',
                                        mask=None,comm=MPI.COMM_WORLD, **kwargs):
    """Create a graph for deconvolution, adding to the model

    :param dirty_list: in rank0
    :param psf_list: in rank0
    :param model_imagelist: in rank0
    :param prefix: Informative prefix to log messages
    :param mask: Mask for deconvolution
    :param comm: MPI communicator
    :param kwargs: Parameters for functions in components
    :return: graph for the deconvolution
    """
    rank = comm.Get_rank()
    size = comm.Get_size()
    nchan = len(dirty_list)
    log.info('%d: deconvolve_list_mpi_workflow: dirty_list len %d psf_list len %d model_imagelist len %d' %(rank,len(dirty_list),len(psf_list),len(model_imagelist)))

    nmoment = get_parameter(kwargs, "nmoment", 0)
    assert get_parameter(kwargs, "use_serial_clean", True),"Only serial deconvolution implemented"
    if get_parameter(kwargs, "use_serial_clean", True):
        from workflows.serial.imaging.imaging_serial import deconvolve_list_serial_workflow
        if rank==0:
            assert isinstance(model_imagelist, list), model_imagelist
            result_list=deconvolve_list_serial_workflow (dirty_list, psf_list, model_imagelist, prefix=prefix, mask=mask, **kwargs)
        else:
            result_list=list()
    return result_list
Create a graph for deconvolution, adding to the model

    :param dirty_list: in rank0
    :param psf_list: in rank0
    :param model_imagelist: in rank0
    :param prefix: Informative prefix to log messages
    :param mask: Mask for deconvolution
    :param comm: MPI communicator
    :param kwargs: Parameters for functions in components
    :return: graph for the deconvolution
    
Create a graph for deconvolution, adding to the model
Create a graph for deconvolution adding to the model
def deconvolve_list_mpi_workflow(dirty_list, psf_list, model_imagelist,
                                        prefix='',
                                        mask=None,comm=MPI.COMM_WORLD, **kwargs):
    rank = comm.Get_rank()
    size = comm.Get_size()
    nchan = len(dirty_list)
    log.info('%d: deconvolve_list_mpi_workflow: dirty_list len %d psf_list len %d model_imagelist len %d' %(rank,len(dirty_list),len(psf_list),len(model_imagelist)))
    nmoment = get_parameter(kwargs, "nmoment", 0)
    assert get_parameter(kwargs, "use_serial_clean", True),"Only serial deconvolution implemented"
    if get_parameter(kwargs, "use_serial_clean", True):
        from workflows.serial.imaging.imaging_serial import deconvolve_list_serial_workflow
        if rank==0:
            assert isinstance(model_imagelist, list), model_imagelist
            result_list=deconvolve_list_serial_workflow (dirty_list, psf_list, model_imagelist, prefix=prefix, mask=mask, **kwargs)
        else:
            result_list=list()
    return result_list
def deconvolve_list_mpi_workflow ( dirty_list , psf_list , model_imagelist , prefix = '' , mask = None , comm = MPI . COMM_WORLD , ** kwargs ) : rank = comm . Get_rank ( ) size = comm . Get_size ( ) nchan = len ( dirty_list ) log . info ( '%d: deconvolve_list_mpi_workflow: dirty_list len %d psf_list len %d model_imagelist len %d' % ( rank , len ( dirty_list ) , len ( psf_list ) , len ( model_imagelist ) ) ) nmoment = get_parameter ( kwargs , "nmoment" , 0 ) assert get_parameter ( kwargs , "use_serial_clean" , True ) , "Only serial deconvolution implemented" if get_parameter ( kwargs , "use_serial_clean" , True ) : from workflows . serial . imaging . imaging_serial import deconvolve_list_serial_workflow if rank == 0 : assert isinstance ( model_imagelist , list ) , model_imagelist result_list = deconvolve_list_serial_workflow ( dirty_list , psf_list , model_imagelist , prefix = prefix , mask = mask , ** kwargs ) else : result_list = list ( ) return result_list
Create a graph for deconvolution, adding to the model
Create a graph for deconvolution adding to the model
"""Create a graph for deconvolution, adding to the model

    :param dirty_list: in rank0
    :param psf_list: in rank0
    :param model_imagelist: in rank0
    :param prefix: Informative prefix to log messages
    :param mask: Mask for deconvolution
    :param comm: MPI communicator
    :param kwargs: Parameters for functions in components
    :return: graph for the deconvolution
    """
graph for the deconvolution
graph for the deconvolution
dirty_list
None
psf_list
None
model_imagelist
None
prefix
Informative prefix to log messages
Informative prefix to log messages
mask
Mask for deconvolution
Mask for deconvolution
comm
None
kwargs
Parameters for functions in components
Parameters for functions in components