first infinite loop function

def run_trade_risk_generation_process(risk_object: USDInflationRiskPnL, write_path: str):
    event_handler = BookRiskFileHandler(write_path, risk_object)
    observer = Observer()
    observer.schedule(event_handler, path=RISK_PATH, recursive=False)
    observer.start()
    try:
        while True:
            time.sleep(1)
        except KeyboardInterrupt:
            observer.stopp()
    observer.join()