def add_callback(self, start_cursor: int, callback: Callable[([EventLogEntry], None)]):
    'Observer has started watching this run.\n            Add a callback to execute on new EventLogEntrys st. id >= start_cursor\n\n        Args:\n            start_cursor (int): minimum event_id for the callback to execute\n            callback (Callable[[EventLogEntry], None]): callback to update the Dagster UI\n        '
    start_cursor = check.int_param(start_cursor, 'start_cursor')
    callback = check.callable_param(callback, 'callback')
    with self._callback_fn_list_lock:
        self._callback_fn_list.append(CallbackAfterCursor(start_cursor, callback))
Observer has started watching this run.
    Add a callback to execute on new EventLogEntrys st. id >= start_cursor

Args:
    start_cursor (int): minimum event_id for the callback to execute
    callback (Callable[[EventLogEntry], None]): callback to update the Dagster UI
def add_callback(self, start_cursor: int, callback: Callable[([EventLogEntry], None)]):
    'Observer has started watching this run.\n            Add a callback to execute on new EventLogEntrys st. id >= start_cursor\n\n        Args:\n            start_cursor (int): minimum event_id for the callback to execute\n            callback (Callable[[EventLogEntry], None]): callback to update the Dagster UI\n        '
    start_cursor = check.int_param(start_cursor, 'start_cursor')
    callback = check.callable_param(callback, 'callback')
    with self._callback_fn_list_lock:
        self._callback_fn_list.append(CallbackAfterCursor(start_cursor, callback))