def METHOD_NAME(self):
    """Test that engine manager does not crash when DAG execution fails on server."""
    event_yielder = self.yield_events_dag_fails()
    attribs = {
        "start_execution.return_value": ("remote_execution_started", "12345", "abcdefg123"),
        "rcv_next.side_effect": event_yielder,
    }
    self._run_engine(attribs)