use create_run_orchestrator

Author: TamarZanzouri

api/src/opentrons/execute.py

@@ -631,28 +631,13 @@ async def run(protocol_source: ProtocolSource) -> None:
             load_fixed_trash=should_load_fixed_trash(protocol_source.config),
         )
 
-        protocol_runner = create_protocol_runner(
-            protocol_config=protocol_source.config,
-            protocol_engine=protocol_engine,
-            hardware_api=hardware_api_wrapped,
-        )
-
-        orchestrator = RunOrchestrator(
+        orchestrator = RunOrchestrator.build_orchestrator(
             hardware_api=hardware_api_wrapped,
             protocol_engine=protocol_engine,
-            json_or_python_protocol_runner=protocol_runner,
-            fixit_runner=LiveRunner(
-                protocol_engine=protocol_engine, hardware_api=hardware_api_wrapped
-            ),
-            setup_runner=LiveRunner(
-                protocol_engine=protocol_engine, hardware_api=hardware_api_wrapped
-            ),
-            protocol_live_runner=LiveRunner(
-                protocol_engine=protocol_engine, hardware_api=hardware_api_wrapped
-            ),
+            protocol_config=protocol_source.config,
         )
 
-        unsubscribe = protocol_runner.broker.subscribe(
+        unsubscribe = orchestrator.get_protocol_runner().broker.subscribe(
             "command", lambda event: emit_runlog(event) if emit_runlog else None
         )
         try: