async def safe_call(self, coro, timeout, operation_desc="operation"):
        """Safely call an async function with a timeout and handle
        exceptions."""
        try:
            return await asyncio.wait_for(coro, timeout=timeout)
        except asyncio.TimeoutError:
            print(
                f"[TIMEOUT] {operation_desc} took longer than {timeout} seconds"
            )
        except Exception as e:
            print(f"[ERROR] Exception during {operation_desc}: {e}")
        return None
Safely call an async function with a timeout and handle
        exceptions.
py/tests/scaling/loadTester.py