in integration/preemption.py [0:0]
def clock(partition: str, duration: int):
log = logging.getLogger(f"preemption_{partition}")
tick_tack = ["tick", "tack"]
try:
for minute in range(duration - 5):
log.info(tick_tack[minute % 2])
time.sleep(60)
logging.warning("*** Exited peacefully ***")
return duration
except:
logging.warning(f"!!! Interrupted on: {datetime.now().isoformat()}")
raise