def __init__(self, event_log_storage: SqlEventLogStorage, run_id: str):
    super(SqlPollingRunIdEventWatcherThread, self).__init__()
    self._event_log_storage = check.inst_param(event_log_storage, 'event_log_storage', SqlEventLogStorage)
    self._run_id = check.str_param(run_id, 'run_id')
    self._callback_fn_list_lock: threading.Lock = threading.Lock()
    self._callback_fn_list: List[CallbackAfterCursor] = []
    self._should_thread_exit = threading.Event()
    self.name = f'mysql-event-watch-run-id-{self._run_id}'
def __init__(self, event_log_storage: SqlEventLogStorage, run_id: str):
    super(SqlPollingRunIdEventWatcherThread, self).__init__()
    self._event_log_storage = check.inst_param(event_log_storage, 'event_log_storage', SqlEventLogStorage)
    self._run_id = check.str_param(run_id, 'run_id')
    self._callback_fn_list_lock: threading.Lock = threading.Lock()
    self._callback_fn_list: List[CallbackAfterCursor] = []
    self._should_thread_exit = threading.Event()
    self.name = f'mysql-event-watch-run-id-{self._run_id}'