@classmethod
    def _notify_continuous_computation_listeners_async(cls, *args, **kwargs):
        taskqueue_services.defer_to_events_queue(
            jobs_registry.ContinuousComputationEventDispatcher.dispatch_event,
            cls.EVENT_TYPE, *args, **kwargs)
Dispatch events asynchronously to continuous computation realtime
dataset/ETHPy150Open oppia/oppia/core/domain/event_services.py/BaseEventHandler._notify_continuous_computation_listeners_async