KekLib.ProgressInfo#
ProgressInfo.py
Copyright (c) 2017-2023, Masatsuyo Takahashi, KEK-PF
- class ExecInfo(**entries)#
Bases:
object
- class ProgressInfo(init_max_dict)#
Bases:
object- get_info(block=False)#
note that get_info is called only in the main thread so that there is no need to care for thread safety.
- get_start_time(stream)#
- get_stream_progresses()#
- get_stream_states()#
- is_end_states(states)#
- set_error()#
- class StreamState(phase, step, state)#
Bases:
object
- cleanup_queues()#
- on_stop_raise(cleanup=None, log_closure=None)#
- put_error(k, step=-1, error_state=-1)#
- put_info(k, step, state=None)#
- put_max_info(stream, max_dict)#
- send_stop()#