from . import flaghelper as fh
from .mstools import write_history
from .parallel.parallel_task_helper import ParallelTaskHelper
from .parallel.parallel_data_helper import ParallelDataHelper
from collections import OrderedDict
from casatasks import casalog
from casatools import ms, agentflagger, quanta, table
class FlagHelper(ParallelTaskHelper):
def __init__(self, args={}):
def setupInputFile(self, parname):
'''Create a temporary input file with
absolute pathnames for other input files
such as addantenna, timedev, freqdev.
The temporary input file will have the same
name with an extension .tmp'''
if isinstance(parname, str) and parname != '':
newpar = fh.addAbsolutePath(parname)
elif isinstance(parname, list) and os.path.isfile(parname[0]):
for i in range(len(parname)):
newpar.append(fh.addAbsolutePath(parname[i]))
def setupCluster(self, thistask=''):
'''Get a cluster to execute this task'''
ParallelTaskHelper.__init__(self, task_name=thistask, args=self.__args)
def setupRflag(self, devpar):
'''cast rflag's list parameters from numpy types to Python types
devpar --> list of numeric parameters or list of list
such as timedev or freqdev'''
nt = copy.deepcopy(devpar)
if (isinstance(nt[i],list)):
for j in range(len(nnt)):
elem = fh.evaluateNumpyType(nnt[j])