async def _call_handle(self, func, *args):
await async_call(func, *args)<EOL>if self.is_finished:<EOL><INDENT>raise FinishQuitException()<EOL><DEDENT>
call and check result of handle_query/read/insert/update