← Back to branch summary

~pconv-team/polconvertsd/trunk-1

« back to all changes in this revision

Viewing changes to polconvert_cli.py

  • Committer: I. Marti-Vidal
  • Date: 2019-06-14 09:36:09 UTC
  • Revision ID: i.marti-vidal@uv.es-20190614093609-k2p1fbrtjn1ay9d3
Newer version (updated) of the EVN-mode calibration

Show diffs side-by-side

added added

removed removed

Lines of Context:
polconvert_cli.py
5
5
#
6
6
import sys
7
7
import os
 
8
import datetime
8
9
#from casac import *
9
10
import casac
10
11
import string
11
12
import time
12
13
import inspect
13
 
import gc
14
14
import numpy
15
15
from casa_stack_manip import stack_frame_find
16
16
from odict import odict
518
518
        mytmp['solveMethod'] = solveMethod
519
519
        mytmp['calstokes'] = calstokes
520
520
        mytmp['calfield'] = calfield
521
 
        pathname="file:///data/SHARED/WORKAREA/ARC_TOOLS/PolConvert/LaunchPad/BZR_SYNC/polconvertsd/"
 
521
        pathname="file:///home/marti/WORKAREA/ARC_TOOLS/PolConvert/polconvertsd/"
522
522
        trec = casac.casac.utils().torecord(pathname+'polconvert.xml')
523
523
 
524
524
        casalog.origin('polconvert')
529
529
          casac.casac.utils().verify(mytmp, trec['polconvert'], True)
530
530
          scriptstr=['']
531
531
          saveinputs = self.__globals__['saveinputs']
 
532
 
 
533
          # Save .last file for this task execution. MPI servers don't write it (CASR-329).
 
534
          from mpi4casa.MPIEnvironment import MPIEnvironment
 
535
          do_full_logging = MPIEnvironment.is_mpi_disabled_or_client()
532
536
          if type(self.__call__.func_defaults) is NoneType:
533
537
              saveinputs=''
534
538
          else:
535
 
              saveinputs('polconvert', 'polconvert.last', myparams, self.__globals__,scriptstr=scriptstr)
 
539
              saveinputs('polconvert', 'polconvert.last', myparams, self.__globals__,scriptstr=scriptstr, do_save_inputs=do_full_logging)
 
540
 
536
541
          tname = 'polconvert'
537
542
          spaces = ' '*(18-len(tname))
538
543
          casalog.post('\n##########################################'+
539
544
                       '\n##### Begin Task: ' + tname + spaces + ' #####')
540
 
          if (casa['state']['telemetry-enabled']):
541
 
              casalog.poststat('Begin Task: ' + tname)
 
545
          # Don't do telemetry from MPI servers (CASR-329)
 
546
          if do_full_logging and casa['state']['telemetry-enabled']:
 
547
              #casalog.poststat('Begin Task: ' + tname)
 
548
              task_starttime = str(datetime.datetime.now())
542
549
          if type(self.__call__.func_defaults) is NoneType:
543
550
              casalog.post(scriptstr[0]+'\n', 'INFO')
544
 
          else :
 
551
          else:
545
552
              casalog.post(scriptstr[1][1:]+'\n', 'INFO')
 
553
 
 
554
          # Effective call to the task as defined in gcwrap/python/scripts/task_*
546
555
          result = polconvert(IDI, OUTPUTIDI, DiFXinput, DiFXcalc, doIF, linAntIdx, Range, ALMAant, spw, calAPP, calAPPTime, APPrefant, gains, interpolation, gainmode, XYavgTime, dterms, amp_norm, XYadd, XYdel, XYratio, usePcal, swapXY, swapRL, feedRotation, IDI_conjugated, plotIF, plotRange, plotAnt, excludeAnts, doSolve, solint, doTest, npix, solveAmp, solveMethod, calstokes, calfield)
547
 
          if (casa['state']['telemetry-enabled']):
548
 
              casalog.poststat('End Task: ' + tname)
 
556
 
 
557
          if do_full_logging and casa['state']['telemetry-enabled']:
 
558
              task_endtime = str(datetime.datetime.now())
 
559
              casalog.poststat( 'Task ' + tname + ' complete. Start time: ' + task_starttime + ' End time: ' + task_endtime )
549
560
          casalog.post('##### End Task: ' + tname + '  ' + spaces + ' #####'+
550
561
                       '\n##########################################')
551
562
 
559
570
             pass
560
571
        casalog.origin('')
561
572
 
562
 
        gc.collect()
563
573
        return result
564
574
#
565
575
#