mycb.initweights(wtmode=wtmode,dowtsp=dowtsp,tsystable=tsystable,gainfield=gainfield,interp=interp,spwmap=spwmap)
from __future__ import absolute_import
from casatasks.private.casa_transition import *
from casatools import calibrater, ms
from casatasks import casalog
from .mstools import write_history
from .parallel.parallel_data_helper import ParallelDataHelper
from .parallel.parallel_task_helper import ParallelTaskHelper
from mstools import write_history
from parallel.parallel_data_helper import ParallelDataHelper
from parallel.parallel_task_helper import ParallelTaskHelper
def initweights(vis=None,wtmode=None,tsystable=None,gainfield=None,interp=None,spwmap=None,dowtsp=None):
casalog.origin('initweights')
if ParallelTaskHelper.isMPIEnabled() and ParallelDataHelper.isMMSAndNotServer(vis):
tsystable = ParallelTaskHelper.findAbsPath(tsystable)
helper = ParallelTaskHelper('initweights', locals())
param_names = initweights.__code__.co_varnames[:initweights.__code__.co_argcount]
param_vals = [vars[p] for p in param_names]
param_vals = [eval(p) for p in param_names]
casalog.post('Updating the history in the output', 'DEBUG1')
write_history(ms, vis, 'initweights', param_names,
except Exception as instance:
casalog.post("*** Error \'%s\' updating HISTORY" % (instance),
if ((type(vis)==str) & (os.path.exists(vis))):
if wtmode.upper().find("TSYS") > -1:
if not os.path.exists(tsystable):
raise Exception('Tsys calibration table %s not found' % tsystable)
mycb.open(vis,compress=False,addcorr=False,addmodel=False)