'Called by the executor with the list of generated events when `run_job` has been successfully called.'

def _run_job_success(self, job_id, events):

    with self._lock:
        self._instances[job_id] -= 1
    for event in events:
        self._scheduler._dispatch_event(event)
