event_timeout_check Namespace Reference

Functions
list[Configurable]	base_config ()
list[Configurable]	add_event_timeout (list[Configurable] conf, int timeout_seconds)
	config ()

Function Documentation

add_event_timeout()

list[Configurable] event_timeout_check.add_event_timeout	(	list[Configurable]	conf,
		int	timeout_seconds )

Take a configuration and adds a check on events reaching a timeout.

Definition at line 47 of file event_timeout_check.py.

) -> list[Configurable]:
    """
    Take a configuration and adds a check on events reaching a timeout.
    """
    # find the ApplicationMgr as we have to tweak its configuration
    app = next(c for c in conf if c.name == "ApplicationMgr")
    # configure a Gaudi::EventWatchdogAlg
    watchdog = C.Gaudi.EventWatchdogAlg(
        EventTimeout=timeout_seconds,  # sleep for this number of seconds
        StackTrace=False,  # no stack trace (may be slow, see issue #349)
        AbortOnTimeout=True,  # kill the process on timeout
    )
    # wrap original list of algorithms into a sequence to ensure the watchdog
    # is executed before everything else
    wrapping_seq = C.Gaudi.Sequencer(
        "SequenceWithTimeout", Sequential=True, Members=[watchdog] + list(app.TopAlg)
    )
    # reset the main list of algorithms
    app.TopAlg = [wrapping_seq]
    # return the tweaked configuration
    return conf + [watchdog, wrapping_seq]
 
 

base_config()

list[Configurable] event_timeout_check.base_config

(

)

Example configuration of a job with no input and a algorithm that looks stuck.

Definition at line 36 of file event_timeout_check.py.

def base_config() -> list[Configurable]:
    """
    Example configuration of a job with no input and a algorithm that looks stuck.
    """
    algorithms = [C.GaudiTesting.SleepyAlg("StuckAlg", SleepTime=3600)]
    app = C.ApplicationMgr(
        EvtSel="NONE", TopAlg=[C.Gaudi.Sequencer("MainSequence", Members=algorithms)]
    )
    return [app] + list(app.TopAlg) + algorithms
 
 

config()

event_timeout_check.config

(

)

Definition at line 72 of file event_timeout_check.py.

def config():
    # get the normal job configuration
    conf = base_config()
    # make sure we stop if an event takes more than 2s
    conf = add_event_timeout(conf, 2)
    return conf