pyrad.flow.main_rt#

pyrad.flow.main_rt(cfgfile_list, starttime=None, endtime=None, infostr_list=None, proc_period=60, proc_finish=None, hide_warnings=False, MULTIPROCESSING_DSET=False, MULTIPROCESSING_PROD=False, USE_CHILD_PROCESS=False)[source]#

main flow control. Processes radar data in real time. The start and end processing times can be determined by the user. This function is inteded for a single radar

Parameters:

  • cfgfile_list (list of str) – path of the main config files

  • starttime, endtime (datetime object) – start and end time of the data to be processed

  • infostr_list (list of str) – Information string about the actual data processing (e.g. ‘RUN57’). This string is added to product files.

  • proc_period (int) – period of time before starting a new processing round (seconds)

  • proc_finish (int or None) – if set to a value the program will be forced to shut down after the value (in seconds) from start time has been exceeded

  • hide_warnings (bool) – if set to true it will hide the warnings during the pyrad processing this is useful when logging the outputs to log files, as they can become very large

  • MULTIPROCESSING_DSET (Bool) – If true the generation of datasets at the same processing level will be parallelized. This requires installation of dask.

  • MULTIPROCESSING_PROD (Bool) – If true the generation of products from each dataset will be parallelized. This requires installation of dask.

  • USE_CHILD_PROCESS (Bool) – If true the reading and processing of the data will be performed by a child process controlled by dask. This is done to make sure all memory used is released.

Returns:

end_proc (Boolean) – If true the program has ended successfully