workflows/arlexecute/pipelines/pipeline_arlexecute.py
def continuum_imaging_list_arlexecute_workflow(vis_list, model_imagelist, context, gcfcf=None,
                                               vis_slices=1, facets=1, **kwargs):
    """ Create graph for the continuum imaging pipeline.
    
    Same as ICAL but with no selfcal.
    
    :param vis_list:
    :param model_imagelist:
    :param context: Imaging context
    :param kwargs: Parameters for functions in components
    :return:
    """
    if gcfcf is None:
        gcfcf = [arlexecute.execute(create_pswf_convolutionfunction)(model_imagelist[0])]
    
    psf_imagelist = invert_list_arlexecute_workflow(vis_list, model_imagelist, context=context, dopsf=True,
                                                    vis_slices=vis_slices, facets=facets, gcfcf=gcfcf, **kwargs)
    
    residual_imagelist = residual_list_arlexecute_workflow(vis_list, model_imagelist, context=context, gcfcf=gcfcf,
                                                           vis_slices=vis_slices, facets=facets, **kwargs)
    
    deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow(residual_imagelist, psf_imagelist,
                                                                     model_imagelist,
                                                                     prefix='cycle 0',
                                                                     **kwargs)
    nmajor = get_parameter(kwargs, "nmajor", 5)
    if nmajor > 1:
        for cycle in range(nmajor):
            prefix = "cycle %d" % (cycle + 1)
            residual_imagelist = residual_list_arlexecute_workflow(vis_list, deconvolve_model_imagelist,
                                                                   context=context, vis_slices=vis_slices,
                                                                   facets=facets,
                                                                   gcfcf=gcfcf, **kwargs)
            deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow(residual_imagelist, psf_imagelist,
                                                                             deconvolve_model_imagelist,
                                                                             prefix=prefix,
                                                                             **kwargs)
    
    residual_imagelist = residual_list_arlexecute_workflow(vis_list, deconvolve_model_imagelist, context=context,
                                                           vis_slices=vis_slices, facets=facets, gcfcf=gcfcf, **kwargs)
    restore_imagelist = restore_list_arlexecute_workflow(deconvolve_model_imagelist, psf_imagelist, residual_imagelist)
    return (deconvolve_model_imagelist, residual_imagelist, restore_imagelist)
 Create graph for the continuum imaging pipeline.
    
    Same as ICAL but with no selfcal.
    
    :param vis_list:
    :param model_imagelist:
    :param context: Imaging context
    :param kwargs: Parameters for functions in components
    :return:
    
Create graph for the continuum imaging pipeline.
Same as ICAL but with no selfcal.
Create graph for the continuum imaging pipeline . Same as ICAL but with no selfcal .
def continuum_imaging_list_arlexecute_workflow(vis_list, model_imagelist, context, gcfcf=None,
                                               vis_slices=1, facets=1, **kwargs):
    if gcfcf is None:
        gcfcf = [arlexecute.execute(create_pswf_convolutionfunction)(model_imagelist[0])]
    psf_imagelist = invert_list_arlexecute_workflow(vis_list, model_imagelist, context=context, dopsf=True,
                                                    vis_slices=vis_slices, facets=facets, gcfcf=gcfcf, **kwargs)
    residual_imagelist = residual_list_arlexecute_workflow(vis_list, model_imagelist, context=context, gcfcf=gcfcf,
                                                           vis_slices=vis_slices, facets=facets, **kwargs)
    deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow(residual_imagelist, psf_imagelist,
                                                                     model_imagelist,
                                                                     prefix='cycle 0',
                                                                     **kwargs)
    nmajor = get_parameter(kwargs, "nmajor", 5)
    if nmajor > 1:
        for cycle in range(nmajor):
            prefix = "cycle %d" % (cycle + 1)
            residual_imagelist = residual_list_arlexecute_workflow(vis_list, deconvolve_model_imagelist,
                                                                   context=context, vis_slices=vis_slices,
                                                                   facets=facets,
                                                                   gcfcf=gcfcf, **kwargs)
            deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow(residual_imagelist, psf_imagelist,
                                                                             deconvolve_model_imagelist,
                                                                             prefix=prefix,
                                                                             **kwargs)
    residual_imagelist = residual_list_arlexecute_workflow(vis_list, deconvolve_model_imagelist, context=context,
                                                           vis_slices=vis_slices, facets=facets, gcfcf=gcfcf, **kwargs)
    restore_imagelist = restore_list_arlexecute_workflow(deconvolve_model_imagelist, psf_imagelist, residual_imagelist)
    return (deconvolve_model_imagelist, residual_imagelist, restore_imagelist)
def continuum_imaging_list_arlexecute_workflow ( vis_list , model_imagelist , context , gcfcf = None , vis_slices = 1 , facets = 1 , ** kwargs ) : if gcfcf is None : gcfcf = [ arlexecute . execute ( create_pswf_convolutionfunction ) ( model_imagelist [ 0 ] ) ] psf_imagelist = invert_list_arlexecute_workflow ( vis_list , model_imagelist , context = context , dopsf = True , vis_slices = vis_slices , facets = facets , gcfcf = gcfcf , ** kwargs ) residual_imagelist = residual_list_arlexecute_workflow ( vis_list , model_imagelist , context = context , gcfcf = gcfcf , vis_slices = vis_slices , facets = facets , ** kwargs ) deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow ( residual_imagelist , psf_imagelist , model_imagelist , prefix = 'cycle 0' , ** kwargs ) nmajor = get_parameter ( kwargs , "nmajor" , 5 ) if nmajor > 1 : for cycle in range ( nmajor ) : prefix = "cycle %d" % ( cycle + 1 ) residual_imagelist = residual_list_arlexecute_workflow ( vis_list , deconvolve_model_imagelist , context = context , vis_slices = vis_slices , facets = facets , gcfcf = gcfcf , ** kwargs ) deconvolve_model_imagelist = deconvolve_list_arlexecute_workflow ( residual_imagelist , psf_imagelist , deconvolve_model_imagelist , prefix = prefix , ** kwargs ) residual_imagelist = residual_list_arlexecute_workflow ( vis_list , deconvolve_model_imagelist , context = context , vis_slices = vis_slices , facets = facets , gcfcf = gcfcf , ** kwargs ) restore_imagelist = restore_list_arlexecute_workflow ( deconvolve_model_imagelist , psf_imagelist , residual_imagelist ) return ( deconvolve_model_imagelist , residual_imagelist , restore_imagelist )
Create graph for the continuum imaging pipeline.
Create graph for the continuum imaging pipeline .
""" Create graph for the continuum imaging pipeline.
    
    Same as ICAL but with no selfcal.
    
    :param vis_list:
    :param model_imagelist:
    :param context: Imaging context
    :param kwargs: Parameters for functions in components
    :return:
    """
None
vis_list
None
model_imagelist
None
context
None
gcfcf
vis_slices
facets
kwargs
Parameters for functions in components
Parameters for functions in components