casa6

from __future__ import absolute_import

import os

import shutil

import string

import copy

import math

​

# get is_CASA6, is_python3

from casatasks.private.casa_transition import *

if is_CASA6:

    from .mstools import write_history

    from casatools import table, ms, mstransformer

    from casatools import measures as me

    from casatasks import casalog

    from .parallel.parallel_data_helper import ParallelDataHelper

else:

    from mstools import write_history

    from taskinit import tbtool,mstool,mttool,metool

    from taskinit import casalog

    from parallel.parallel_data_helper import ParallelDataHelper

​

def phaseshift(

    vis=None, outputvis=None, keepmms=None, field=None, spw=None, 

    scan=None, intent=None, array=None, observation=None,

    datacolumn=None, phasecenter=None

):

​

    """Changes the phase center for either short or large offsets/angles w.r.t. the original

​

    """

​

    casalog.origin('phaseshift')

    # Initiate the helper class    

    pdh = ParallelDataHelper("phaseshift", locals()) 

​

    # Validate input and output parameters

    try:

        pdh.setupIO()

    except Exception as instance:

        casalog.post('%s'%instance,'ERROR')

        return False

​

    # Input vis is an MMS

    if pdh.isMMSAndNotServer(vis) and keepmms:

        if not pdh.validateInputParams():        

            raise Exception('Unable to continue with MMS processing')

        pdh.setupCluster('phaseshift')

​

        # Execute the jobs

        try:

            pdh.go()

        except Exception as instance:

            casalog.post('%s'%instance,'ERROR')

            return False

        return True

​

​

    # Create local copies of tools (has to be here, otherwise