pipeline.hifa.tasks.importdata.dbfluxes

Functions

add_catalogue_fluxes(measurements, ms)

buildparams(name, date, frequency)

Inputs are all strings with the format: NAME=3c279&DATE=04-Apr-2014&FREQUENCY=231.435E9&WEIGHTED=true&RESULT=1

buildurl(service_url, obs_time, frequency, …)

flux_nosourcexml(ms)

Call the flux service and get the frequencies from the ms if no Source.xml is available

fluxservice(service_url, obs_time, …)

Usage of this online service requires:

get_setjy_results(mses)

Get flux values from the database service reverting to the Source tables XML for backup values and store the values in the context

log_result(source, spw, asdm_I, catalogue_I, …)

query_online_catalogue(flux_url, ms, spw, source)

read_fluxes_db(ms)

Read fluxes from the database server, defaulting to the Source XML table if no fluxes can be found

sanitize_string(name)

Sanitize source name if needed, taking first alias.