Meersolar Pipeline Module¶

This module does all pipeline handling all calibration and imaging jobs and provides command-line interface.

meersolar.meerpipeline.basic_cal module¶

meersolar.meerpipeline.do_apply_basiccal module¶

meersolar.meerpipeline.do_apply_selfcal module¶

meersolar.meerpipeline.do_fluxcal module¶

meersolar.meerpipeline.do_imaging module¶

meersolar.meerpipeline.do_partition module¶

meersolar.meerpipeline.do_selfcal module¶

meersolar.meerpipeline.do_sidereal_cor module¶

meersolar.meerpipeline.do_target_split module¶

meersolar.meerpipeline.flagging module¶

meersolar.meerpipeline.import_model module¶

meersolar.meerpipeline.init_data module¶

meersolar.meerpipeline.init_data.cli()[source]¶

meersolar.meerpipeline.init_data.download_with_parfive(record_id, update=False, output_dir='zenodo_download')[source]¶

meersolar.meerpipeline.init_data.get_zenodo_file_urls(record_id)[source]¶

meersolar.meerpipeline.init_data.init_meersolar_data(update=False, remote_link=None, emails=None)[source]¶

Initiate MeerSOLAR data

Parameters:

update (bool, optional) – Update data, if already exists
remote_link (str, optional) – Remote logger link to save in database
emails (str, optional) – Email addresses to send remote logger JobID and password

meersolar.meerpipeline.init_data.main(init=False, datadir='', update=False, link=None, emails=None)[source]¶

Initiate MeerSOLAR setup

Parameters:

init (bool, optional) – Initiate setup
datadir (str, optional) – User provided custom data directory
update (bool, optional) – Update existing data (if corrupted by somehow)
link (str) – Remote link
emails (str) – E-mails for notifications

meersolar.meerpipeline.kill_job module¶

meersolar.meerpipeline.kill_job.force_kill_pids_with_children(pids, max_tries=10, wait_time=0.5)[source]¶: Repeatedly try to kill all PIDs (and their children) until none remain.

meersolar.meerpipeline.kill_job.kill_meerjob()[source]¶: Kill MeerSOLAR Job

meersolar.meerpipeline.kill_job.kill_process_and_children(pid)[source]¶

meersolar.meerpipeline.master_controller module¶

meersolar.meerpipeline.meer_make_ds module¶

meersolar.meerpipeline.meer_pbcor module¶

meersolar.meerpipeline.show_msdetails module¶

meersolar.meerpipeline.show_msdetails.cli()[source]¶

meersolar.meerpipeline.show_msdetails.show_listobs(msname)[source]¶

meersolar.meerpipeline.show_status module¶

meersolar.meerpipeline.show_status.cli()[source]¶

meersolar.meerpipeline.show_status.show_job_status(clean_old_jobs=False)[source]¶

Show MeerSOLAR jobs status

Parameters:: clean_old_jobs (bool, optional) – Clean old informations for stopped jobs

meersolar.meerpipeline.single_image_meerpbcor module¶

meersolar.meerpipeline.viewer module¶

class meersolar.meerpipeline.viewer.LogViewer(max_lines=10000)[source]¶

Bases: QWidget

append_log_line(text)[source]¶

calc_list_width()[source]¶

closeEvent(self, a0: QCloseEvent | None)[source]¶

load_log_content(item)[source]¶

refresh_logs()[source]¶

setup_ui()[source]¶

class meersolar.meerpipeline.viewer.SmartDefaultsHelpFormatter(prog, indent_increment=2, max_help_position=24, width=None)[source]¶: Bases: ArgumentDefaultsHelpFormatter

class meersolar.meerpipeline.viewer.TailWatcher(file_path)[source]¶

Bases: FileSystemEventHandler, QObject

new_line¶

int = …, arguments: Sequence = …) -> PYQT_SIGNAL

types is normally a sequence of individual types. Each type is either a type object or a string that is the name of a C++ type. Alternatively each type could itself be a sequence of types each describing a different overloaded signal. name is the optional C++ name of the signal. If it is not specified then the name of the class attribute that is bound to the signal is used. revision is the optional revision of the signal that is exported to QML. If it is not specified then 0 is used. arguments is the optional sequence of the names of the signal’s arguments.

Type:: pyqtSignal(*types, name
Type:: str = …, revision

on_modified(event)[source]¶

Called when a file or directory is modified.

Parameters:: event (DirModifiedEvent or FileModifiedEvent) – Event representing file/directory modification.

start()[source]¶

stop()[source]¶

meersolar.meerpipeline.viewer.cli()[source]¶

meersolar.meerpipeline.viewer.drop_cache(path, verbose=False)[source]¶

Drop file cache for a file or all files under a directory.

Parameters:: path (str) – File or directory path

meersolar.meerpipeline.viewer.drop_file_cache(filepath, verbose=False)[source]¶: Advise the OS to drop the given file from the page cache. Safe, per-file, no sudo required.

meersolar.meerpipeline.viewer.get_cachedir()[source]¶

meersolar.meerpipeline.viewer.get_logid(logfile)[source]¶: Get log id for remote logger from logfile name