pipeline package¶
Subpackages¶
- pipeline.domain package
- Submodules
- pipeline.domain.antenna module
- pipeline.domain.antennaarray module
- pipeline.domain.datadescription module
- pipeline.domain.datatable module
- pipeline.domain.field module
- pipeline.domain.fluxmeasurement module
- pipeline.domain.measurementset module
- pipeline.domain.measures module
- pipeline.domain.observingrun module
- pipeline.domain.polarization module
- pipeline.domain.scan module
- pipeline.domain.singledish module
- pipeline.domain.source module
- pipeline.domain.spectralwindow module
- pipeline.domain.state module
- pipeline.domain.unitformat module
- Module contents
- pipeline.extern package
- Subpackages
- pipeline.extern.logutils package
- Submodules
- pipeline.extern.logutils.adapter module
- pipeline.extern.logutils.colorize module
- pipeline.extern.logutils.dictconfig module
- pipeline.extern.logutils.http module
- pipeline.extern.logutils.queue module
- pipeline.extern.logutils.redis module
- pipeline.extern.logutils.testing module
- Module contents
- pipeline.extern.logutils package
- Submodules
- pipeline.extern.XmlObjectifier module
- pipeline.extern.adopted module
- pipeline.extern.asizeof module
- pipeline.extern.findContinuum module
- pipeline.extern.ps_mem module
- pipeline.extern.sensitivity_improvement module
- Module contents
- Subpackages
- pipeline.h package
- Subpackages
- pipeline.h.cli package
- Subpackages
- Submodules
- pipeline.h.cli.cli module
- pipeline.h.cli.h_applycal module
- pipeline.h.cli.h_export_calstate module
- pipeline.h.cli.h_exportdata module
- pipeline.h.cli.h_import_calstate module
- pipeline.h.cli.h_importdata module
- pipeline.h.cli.h_init module
- pipeline.h.cli.h_mssplit module
- pipeline.h.cli.h_restoredata module
- pipeline.h.cli.h_resume module
- pipeline.h.cli.h_save module
- pipeline.h.cli.h_show_calstate module
- pipeline.h.cli.h_tsyscal module
- pipeline.h.cli.h_weblog module
- pipeline.h.cli.hpc_h_applycal module
- pipeline.h.cli.utils module
- Module contents
- pipeline.h.heuristics package
- pipeline.h.tasks package
- pipeline.h.templates package
- pipeline.h.cli package
- Module contents
- Subpackages
- pipeline.hif package
- Subpackages
- pipeline.hif.cli package
- Subpackages
- Submodules
- pipeline.hif.cli.hif_analyzealpha module
- pipeline.hif.cli.hif_antpos module
- pipeline.hif.cli.hif_applycal module
- pipeline.hif.cli.hif_bandpass module
- pipeline.hif.cli.hif_checkproductsize module
- pipeline.hif.cli.hif_correctedampflag module
- pipeline.hif.cli.hif_editimlist module
- pipeline.hif.cli.hif_findcont module
- pipeline.hif.cli.hif_gaincal module
- pipeline.hif.cli.hif_lowgainflag module
- pipeline.hif.cli.hif_makecutoutimages module
- pipeline.hif.cli.hif_makeimages module
- pipeline.hif.cli.hif_makeimlist module
- pipeline.hif.cli.hif_makermsimages module
- pipeline.hif.cli.hif_mstransform module
- pipeline.hif.cli.hif_polarization module
- pipeline.hif.cli.hif_rawflagchans module
- pipeline.hif.cli.hif_refant module
- pipeline.hif.cli.hif_setjy module
- pipeline.hif.cli.hif_setmodels module
- pipeline.hif.cli.hif_transformimagedata module
- pipeline.hif.cli.hif_uvcontfit module
- pipeline.hif.cli.hif_uvcontsub module
- pipeline.hif.cli.hpc_hif_applycal module
- pipeline.hif.cli.hpc_hif_refant module
- pipeline.hif.cli.uvcontfit module
- Module contents
- pipeline.hif.heuristics package
- Submodules
- pipeline.hif.heuristics.bandpass module
- pipeline.hif.heuristics.bporder module
- pipeline.hif.heuristics.checkproductsize module
- pipeline.hif.heuristics.cleanbox module
- pipeline.hif.heuristics.findcont module
- pipeline.hif.heuristics.findrefant module
- pipeline.hif.heuristics.gaincal module
- pipeline.hif.heuristics.imageparams_alma module
- pipeline.hif.heuristics.imageparams_base module
- pipeline.hif.heuristics.imageparams_factory module
- pipeline.hif.heuristics.imageparams_vla module
- pipeline.hif.heuristics.imageparams_vlass_quick_look module
- pipeline.hif.heuristics.imageparams_vlass_single_epoch_continuum module
- pipeline.hif.heuristics.imageparams_vlass_single_epoch_cube module
- pipeline.hif.heuristics.imageparams_vlass_single_epoch_taper module
- pipeline.hif.heuristics.mosaicoverlap module
- pipeline.hif.heuristics.solint module
- pipeline.hif.heuristics.standard module
- Module contents
- pipeline.hif.tasks package
- pipeline.hif.templates package
- pipeline.hif.cli package
- Module contents
- Subpackages
- pipeline.hifa package
- Subpackages
- pipeline.hifa.cli package
- Subpackages
- Submodules
- pipeline.hifa.cli.hifa_antpos module
- pipeline.hifa.cli.hifa_bandpass module
- pipeline.hifa.cli.hifa_bandpassflag module
- pipeline.hifa.cli.hifa_bpsolint module
- pipeline.hifa.cli.hifa_exportdata module
- pipeline.hifa.cli.hifa_flagdata module
- pipeline.hifa.cli.hifa_flagtargets module
- pipeline.hifa.cli.hifa_fluxcalflag module
- pipeline.hifa.cli.hifa_gaincalsnr module
- pipeline.hifa.cli.hifa_gfluxscale module
- pipeline.hifa.cli.hifa_gfluxscaleflag module
- pipeline.hifa.cli.hifa_imageprecheck module
- pipeline.hifa.cli.hifa_importdata module
- pipeline.hifa.cli.hifa_lock_refant module
- pipeline.hifa.cli.hifa_polcalflag module
- pipeline.hifa.cli.hifa_restoredata module
- pipeline.hifa.cli.hifa_session_bandpass module
- pipeline.hifa.cli.hifa_session_refant module
- pipeline.hifa.cli.hifa_spwphaseup module
- pipeline.hifa.cli.hifa_targetflag module
- pipeline.hifa.cli.hifa_timegaincal module
- pipeline.hifa.cli.hifa_tsysflag module
- pipeline.hifa.cli.hifa_unlock_refant module
- pipeline.hifa.cli.hifa_wvrgcal module
- pipeline.hifa.cli.hifa_wvrgcalflag module
- Module contents
- pipeline.hifa.heuristics package
- Submodules
- pipeline.hifa.heuristics.atm module
- pipeline.hifa.heuristics.exptimes module
- pipeline.hifa.heuristics.fluxscale module
- pipeline.hifa.heuristics.imageprecheck module
- pipeline.hifa.heuristics.phasespwmap module
- pipeline.hifa.heuristics.snr module
- pipeline.hifa.heuristics.wvrgcal module
- Module contents
- pipeline.hifa.tasks package
- pipeline.hifa.templates package
- pipeline.hifa.cli package
- Module contents
- Subpackages
- pipeline.hifas package
- pipeline.hifv package
- Subpackages
- pipeline.hifv.cli package
- Subpackages
- Submodules
- pipeline.hifv.cli.hifv_applycals module
- pipeline.hifv.cli.hifv_checkflag module
- pipeline.hifv.cli.hifv_circfeedpolcal module
- pipeline.hifv.cli.hifv_exportdata module
- pipeline.hifv.cli.hifv_exportvlassdata module
- pipeline.hifv.cli.hifv_finalcals module
- pipeline.hifv.cli.hifv_fixpointing module
- pipeline.hifv.cli.hifv_flagbaddef module
- pipeline.hifv.cli.hifv_flagcal module
- pipeline.hifv.cli.hifv_flagdata module
- pipeline.hifv.cli.hifv_fluxboot module
- pipeline.hifv.cli.hifv_fluxboot2 module
- pipeline.hifv.cli.hifv_gaincurves module
- pipeline.hifv.cli.hifv_hanning module
- pipeline.hifv.cli.hifv_importdata module
- pipeline.hifv.cli.hifv_opcal module
- pipeline.hifv.cli.hifv_pbcor module
- pipeline.hifv.cli.hifv_plotsummary module
- pipeline.hifv.cli.hifv_priorcals module
- pipeline.hifv.cli.hifv_restoredata module
- pipeline.hifv.cli.hifv_rqcal module
- pipeline.hifv.cli.hifv_selfcal module
- pipeline.hifv.cli.hifv_semiFinalBPdcals module
- pipeline.hifv.cli.hifv_solint module
- pipeline.hifv.cli.hifv_statwt module
- pipeline.hifv.cli.hifv_swpowcal module
- pipeline.hifv.cli.hifv_syspower module
- pipeline.hifv.cli.hifv_targetflag module
- pipeline.hifv.cli.hifv_tecmaps module
- pipeline.hifv.cli.hifv_testBPdcals module
- pipeline.hifv.cli.hifv_vlasetjy module
- Module contents
- pipeline.hifv.heuristics package
- Submodules
- pipeline.hifv.heuristics.bandpass module
- pipeline.hifv.heuristics.lib_EVLApipeutils module
- pipeline.hifv.heuristics.standard module
- pipeline.hifv.heuristics.standard_test module
- pipeline.hifv.heuristics.uvrange module
- pipeline.hifv.heuristics.uvrange_test module
- pipeline.hifv.heuristics.vlascanheuristics module
- Module contents
- pipeline.hifv.tasks package
- pipeline.hifv.templates package
- pipeline.hifv.cli package
- Module contents
- Subpackages
- pipeline.hsd package
- Subpackages
- pipeline.hsd.cli package
- Subpackages
- Submodules
- pipeline.hsd.cli.hsd_applycal module
- pipeline.hsd.cli.hsd_baseline module
- pipeline.hsd.cli.hsd_blflag module
- pipeline.hsd.cli.hsd_exportdata module
- pipeline.hsd.cli.hsd_flagdata module
- pipeline.hsd.cli.hsd_imaging module
- pipeline.hsd.cli.hsd_importdata module
- pipeline.hsd.cli.hsd_k2jycal module
- pipeline.hsd.cli.hsd_restoredata module
- pipeline.hsd.cli.hsd_skycal module
- pipeline.hsd.cli.hsd_tsysflag module
- Module contents
- pipeline.hsd.heuristics package
- Submodules
- pipeline.hsd.heuristics.MaskDeviation module
- pipeline.hsd.heuristics.baselineparamconfig module
- pipeline.hsd.heuristics.fitorder module
- pipeline.hsd.heuristics.fragmentation module
- pipeline.hsd.heuristics.grouping2 module
- pipeline.hsd.heuristics.grouping2_test module
- pipeline.hsd.heuristics.observingpattern2 module
- pipeline.hsd.heuristics.sdbeamsize module
- pipeline.hsd.heuristics.sdcaltype module
- pipeline.hsd.heuristics.sddatatype module
- pipeline.hsd.heuristics.tsysspwmap module
- Module contents
- pipeline.hsd.tasks package
- pipeline.hsd.templates package
- pipeline.hsd.cli package
- Module contents
- Subpackages
- pipeline.hsdn package
- pipeline.infrastructure package
- Subpackages
- pipeline.infrastructure.displays package
- Submodules
- pipeline.infrastructure.displays.plotmosaic module
- pipeline.infrastructure.displays.plotpwv module
- pipeline.infrastructure.displays.plotstyle module
- pipeline.infrastructure.displays.plotweather module
- pipeline.infrastructure.displays.pointing module
- pipeline.infrastructure.displays.summary module
- Module contents
- pipeline.infrastructure.docutils package
- pipeline.infrastructure.new_pipeline_task package
- pipeline.infrastructure.renderer package
- Subpackages
- Submodules
- pipeline.infrastructure.renderer.basetemplates module
- pipeline.infrastructure.renderer.htmlrenderer module
- pipeline.infrastructure.renderer.logger module
- pipeline.infrastructure.renderer.qaadapter module
- pipeline.infrastructure.renderer.registry module
- pipeline.infrastructure.renderer.regression module
- pipeline.infrastructure.renderer.rendererutils module
- pipeline.infrastructure.renderer.weblog module
- Module contents
- pipeline.infrastructure.utils package
- Submodules
- pipeline.infrastructure.utils.conversion module
- pipeline.infrastructure.utils.conversion_test module
- pipeline.infrastructure.utils.diagnostics module
- pipeline.infrastructure.utils.framework module
- pipeline.infrastructure.utils.imaging module
- pipeline.infrastructure.utils.imaging_test module
- pipeline.infrastructure.utils.math module
- pipeline.infrastructure.utils.math_test module
- pipeline.infrastructure.utils.positioncorrection module
- pipeline.infrastructure.utils.positioncorrection_test module
- pipeline.infrastructure.utils.ppr module
- pipeline.infrastructure.utils.sorting module
- pipeline.infrastructure.utils.sorting_test module
- pipeline.infrastructure.utils.utils module
- pipeline.infrastructure.utils.utils_test module
- pipeline.infrastructure.utils.weblog module
- Module contents
- pipeline.infrastructure.displays package
- Submodules
- pipeline.infrastructure.adapters module
- pipeline.infrastructure.api module
- pipeline.infrastructure.argmapper module
- pipeline.infrastructure.basetask module
- pipeline.infrastructure.callibrary module
- pipeline.infrastructure.casa_tasks module
- pipeline.infrastructure.casa_tools module
- pipeline.infrastructure.contfilehandler module
- pipeline.infrastructure.exceptions module
- pipeline.infrastructure.executeppr module
- pipeline.infrastructure.executevlappr module
- pipeline.infrastructure.filenamer module
- pipeline.infrastructure.imageheader module
- pipeline.infrastructure.imagelibrary module
- pipeline.infrastructure.jobrequest module
- pipeline.infrastructure.launcher module
- pipeline.infrastructure.logging module
- pipeline.infrastructure.mpihelpers module
- pipeline.infrastructure.pipelineqa module
- pipeline.infrastructure.project module
- pipeline.infrastructure.sessionutils module
- pipeline.infrastructure.tablereader module
- pipeline.infrastructure.taskregistry module
- pipeline.infrastructure.vdp module
- Module contents
- Subpackages
- pipeline.qa package
Submodules¶
pipeline.environment module¶
environment.py defines functions and variables related to the execution environment.
-
pipeline.environment.
compare_casa_version
(op, ver)¶
pipeline.recipereducer module¶
recipereducer is a utility to reduce data using a standard pipeline procedure. It parses a XML reduction recipe, converts it to pipeline tasks, and executes the tasks for the given data. It was written to give pipeline developers without access to PPRs and/or a PPR generator a way to reduce data using the latest standard recipe.
- Note: multiple input datasets can be specified. Doing so will reduce the data
as part of the same session.
Example #1: process uid123.tar.gz using the standard recipe.
import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’])
Example #2: process uid123.tar.gz using a named recipe.
import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’],
procedure=’procedure_hif.xml’)
Example #3: process uid123.tar.gz and uid124.tar.gz using the standard recipe.
import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’, ‘uid124.tar.gz’])
- Example #4: process uid123.tar.gz, naming the context ‘testrun’, thus
directing all weblog output to a directory called ‘testrun’.
import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’], name=’testrun’)
Example #5: process uid123.tar.gz with a log level of TRACE
import pipeline.recipereducer pipeline.recipereducer.reduce(vis=[‘uid123.tar.gz’], loglevel=’trace’)
-
class
pipeline.recipereducer.
TaskArgs
(vis, infiles, session)¶ Bases:
tuple
-
property
infiles
¶ Alias for field number 1
-
property
session
¶ Alias for field number 2
-
property
vis
¶ Alias for field number 0
-
property
Module contents¶
-
pipeline.
show_weblog
(index_path='', handler_class=<class 'http.server.SimpleHTTPRequestHandler'>, server_class=<class 'http.server.HTTPServer'>, bind='127.0.0.1')[source]¶ Locate the most recent web log and serve it via a HTTP server running on 127.0.0.1 using a random port 30000-32768.
The function arguments are not exposed in the CASA CLI interface, but are made available in case that becomes necessary.
TODO: Ideally we’d serve just the html directory, but that breaks the weblog for reasons I don’t have time to investigate right now. See https://gist.github.com/diegosorrilha/812787c01b65fde6dec870ab97212abd , which is easily convertible to Python 3. These classes can be passed in as handler_class and server_class arguments.