|
|
@@ -123,6 +123,7 @@ async def run_controller(
|
|
|
|
|
|
if runtime is None:
|
|
|
runtime = create_runtime(config, sid=sid)
|
|
|
+ await runtime.connect()
|
|
|
|
|
|
event_stream = runtime.event_stream
|
|
|
|
|
|
@@ -188,8 +189,6 @@ async def run_controller(
|
|
|
|
|
|
event_stream.subscribe(EventStreamSubscriber.MAIN, on_event, sid)
|
|
|
|
|
|
- await runtime.connect()
|
|
|
-
|
|
|
end_states = [
|
|
|
AgentState.FINISHED,
|
|
|
AgentState.REJECTED,
|