def run(self):
    'Polling function to update Observers with EventLogEntrys from Event Log DB.\n        Wakes every POLLING_CADENCE &\n            1. executes a SELECT query to get new EventLogEntrys\n            2. fires each callback (taking into account the callback.cursor) on the new EventLogEntrys\n        Uses max_index_so_far as a cursor in the DB to make sure that only new records are retrieved\n        '
    cursor = (- 1)
    while (not self._should_thread_exit.wait(POLLING_CADENCE)):
        events = self._event_log_storage.get_logs_for_run(self._run_id, cursor=cursor)
        for event_record in events:
            cursor += 1
            with self._callback_fn_list_lock:
                for callback_with_cursor in self._callback_fn_list:
                    if (callback_with_cursor.start_cursor < cursor):
                        callback_with_cursor.callback(event_record)
Polling function to update Observers with EventLogEntrys from Event Log DB.
Wakes every POLLING_CADENCE &
    1. executes a SELECT query to get new EventLogEntrys
    2. fires each callback (taking into account the callback.cursor) on the new EventLogEntrys
Uses max_index_so_far as a cursor in the DB to make sure that only new records are retrieved
def run(self):
    'Polling function to update Observers with EventLogEntrys from Event Log DB.\n        Wakes every POLLING_CADENCE &\n            1. executes a SELECT query to get new EventLogEntrys\n            2. fires each callback (taking into account the callback.cursor) on the new EventLogEntrys\n        Uses max_index_so_far as a cursor in the DB to make sure that only new records are retrieved\n        '
    cursor = (- 1)
    while (not self._should_thread_exit.wait(POLLING_CADENCE)):
        events = self._event_log_storage.get_logs_for_run(self._run_id, cursor=cursor)
        for event_record in events:
            cursor += 1
            with self._callback_fn_list_lock:
                for callback_with_cursor in self._callback_fn_list:
                    if (callback_with_cursor.start_cursor < cursor):
                        callback_with_cursor.callback(event_record)