pipeline.qa package

Subpackages

• pipeline.qa.utility package
  • Submodules
  • pipeline.qa.utility.filters module
  • pipeline.qa.utility.logs module
  • pipeline.qa.utility.scorers module
  • Module contents

Submodules

pipeline.qa.bpcal module

pipeline.qa.bpcal.MAD(a, c=0.6745, axis=None)

Median Absolute Deviation along given axis of an array:

median(abs(a - median(a))) / c

c = 0.6745 is the constant to convert from MAD to std; it is used by default

pipeline.qa.bpcal.bpcal(in_table, out_dir, logobj='PYTHON', create_plots=False)

pipeline.qa.bpcal.bpcal_calc(in_table, logger='')

pipeline.qa.bpcal.bpcal_chanRangeList(numchan, trim=0.1)

pipeline.qa.bpcal.bpcal_desc()

pipeline.qa.bpcal.bpcal_desc_st()

pipeline.qa.bpcal.bpcal_plot(in_table, out_dir, bpcal_stats)

pipeline.qa.bpcal.bpcal_plot1(in_table, out_dir, stats_dict, spw, chanRange, iteration, ap)

pipeline.qa.bpcal.bpcal_plot_hist(in_table, out_dir, stats, ap='AMPLITUDE', hist='FLAG')

pipeline.qa.bpcal.bpcal_putFitRow(tbLoc, spw, chanRange, dictRow, row)

pipeline.qa.bpcal.bpcal_score(bpcal_stats)

pipeline.qa.bpcal.bpcal_score_RMS(RMS, RMSMax)

pipeline.qa.bpcal.bpcal_score_SNR(SNR)

pipeline.qa.bpcal.bpcal_score_delay(delay, delayErr, freqs, phases, flags, chanRange)

pipeline.qa.bpcal.bpcal_score_derivative_deviation(values)

pipeline.qa.bpcal.bpcal_score_flag(flags, chanRange)

pipeline.qa.bpcal.bpcal_score_flatness(values)

pipeline.qa.bpcal.bpcal_spwChanString(spw, sschan)

pipeline.qa.bpcal.bpcal_write(bpcal_stats, out_table)

pipeline.qa.bpcal.nanmedian(arr, **kwargs)

Returns median ignoring NAN

pipeline.qa.bpcal.rms(data)

pipeline.qa.checksource module

pipeline.qa.checksource.checkimage(imagename, rms, refdirection, refflux)

imagename - The image of the source

rms - The image rms

refdirection - The reference direction measure for the source that is imaged

refflux - The reference flux quanta for the source that is imaged. It may be None

pipeline.qa.checksource.fitimage(imagename, rms, fitradius=15)

imagename - The image of the source

rms - The image rms

radius - The radius of a circular region around the center of the imaged

used to computed the fit paramaters and image statistics

pipeline.qa.gpcal module

pipeline.qa.gpcal.gpcal(caltable)

pipeline.qa.gpcal.gpcal_calc(caltable)

Calculate X-Y and X2-X1 phase calibration statistics for int based phase calibration tables.

pipeline.qa.gpcal.gpcal_score(gpcal_stats)

Calculate scores for phase statistics.

pipeline.qa.scorecalculator module

Created on 9 Jan 2014

@author: sjw

pipeline.qa.scorecalculator.score_applycal_agents(self, *args, **kw)

pipeline.qa.scorecalculator.score_applycmds_exist(self, *args, **kw)

pipeline.qa.scorecalculator.score_bands(self, *args, **kw)

pipeline.qa.scorecalculator.score_bwswitching(self, *args, **kw)

pipeline.qa.scorecalculator.score_caltables_exist(self, *args, **kw)

pipeline.qa.scorecalculator.score_checksources(self, *args, **kw)

pipeline.qa.scorecalculator.score_contiguous_session(self, *args, **kw)

pipeline.qa.scorecalculator.score_derived_fluxes_snr(self, *args, **kw)

pipeline.qa.scorecalculator.score_ephemeris_coordinates(self, *args, **kw)

pipeline.qa.scorecalculator.score_file_exists(self, *args, **kw)

pipeline.qa.scorecalculator.score_flagged_vla_baddef(self, *args, **kw)

pipeline.qa.scorecalculator.score_flagging_view_exists(self, *args, **kw)

pipeline.qa.scorecalculator.score_flags_exist(self, *args, **kw)

pipeline.qa.scorecalculator.score_fluxservice(result)

If the primary FS query fails and the backup is invoked, the severity level should be BLUE (below standard; numerically, on its own, 0.9). If the backup FS query also fails, the warning should be YELLOW (WARNING; numerically, on its own, 0.6). But it should keep running as it currently does.

pipeline.qa.scorecalculator.score_gfluxscale_k_spw(self, *args, **kw)

pipeline.qa.scorecalculator.score_missing_bandpass_snrs(self, *args, **kw)

pipeline.qa.scorecalculator.score_missing_derived_fluxes(self, *args, **kw)

pipeline.qa.scorecalculator.score_missing_intents(self, *args, **kw)

pipeline.qa.scorecalculator.score_missing_phase_snrs(self, *args, **kw)

pipeline.qa.scorecalculator.score_missing_phaseup_snrs(self, *args, **kw)

pipeline.qa.scorecalculator.score_mom8_fc_image(mom8_fc_name, peak_snr, cube_chanScaled_MAD, outlier_threshold, n_pixels, n_outlier_pixels, is_eph_obj=False)

Check the MOM8 FC image for outliers above a given SNR threshold. The score can vary between 0.33 and 1.0 depending on the fraction of outlier pixels.

pipeline.qa.scorecalculator.score_ms_history_entries_present(self, *args, **kw)

pipeline.qa.scorecalculator.score_ms_model_data_column_present(all_mses, mses_with_column)

Give a score for a group of mses based on the number with modeldata columns present. None with modeldata - 100% with modeldata = 1.0 -> 0.5

pipeline.qa.scorecalculator.score_mses_exist(self, *args, **kw)

pipeline.qa.scorecalculator.score_multiply(self, *args, **kw)

pipeline.qa.scorecalculator.score_number_antenna_offsets(self, *args, **kw)

pipeline.qa.scorecalculator.score_online_shadow_template_agents(self, *args, **kw)

pipeline.qa.scorecalculator.score_path_exists(self, *args, **kw)

pipeline.qa.scorecalculator.score_phaseup_mapping_fraction(self, *args, **kw)

pipeline.qa.scorecalculator.score_polintents(self, *args, **kw)

pipeline.qa.scorecalculator.score_poor_bandpass_solutions(self, *args, **kw)

pipeline.qa.scorecalculator.score_poor_phase_snrs(self, *args, **kw)

pipeline.qa.scorecalculator.score_poor_phaseup_solutions(self, *args, **kw)

pipeline.qa.scorecalculator.score_refspw_mapping_fraction(self, *args, **kw)

pipeline.qa.scorecalculator.score_setjy_measurements(self, *args, **kw)

pipeline.qa.scorecalculator.score_total_data_flagged(self, *args, **kw)

pipeline.qa.scorecalculator.score_total_data_flagged_vla(self, *args, **kw)

pipeline.qa.scorecalculator.score_total_data_flagged_vla_bandpass(self, *args, **kw)

pipeline.qa.scorecalculator.score_total_data_vla_delay(self, *args, **kw)

pipeline.qa.scorecalculator.score_tsysspwmap(self, *args, **kw)

pipeline.qa.scorecalculator.score_vla_agents(self, *args, **kw)

pipeline.qa.scorecalculator.score_vla_flux_residual_rms(self, *args, **kw)

Module contents