def __init__(self, event_log_storage: SqlEventLogStorage):
    self._event_log_storage = check.inst_param(event_log_storage, 'event_log_storage', SqlEventLogStorage)
    self._dict_lock: threading.Lock = threading.Lock()
    self._run_id_to_watcher_dict: MutableMapping[(str, SqlPollingRunIdEventWatcherThread)] = {}
    self._disposed = False
def __init__(self, event_log_storage: SqlEventLogStorage):
    self._event_log_storage = check.inst_param(event_log_storage, 'event_log_storage', SqlEventLogStorage)
    self._dict_lock: threading.Lock = threading.Lock()
    self._run_id_to_watcher_dict: MutableMapping[(str, SqlPollingRunIdEventWatcherThread)] = {}
    self._disposed = False