File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -667,7 +667,6 @@ def run_blocking(self) -> None:
667667 force_single_process = self ._force_single_process , wait_for_ready = False
668668 ):
669669 return
670- self ._started = True
671670 self ._run_main_process ()
672671
673672 def _initialize (self , force_single_process : bool , wait_for_ready : bool ) -> bool :
@@ -767,11 +766,12 @@ def _run_main_process(self) -> None:
767766 if self ._execution_context is None or self ._loop is None :
768767 return
769768 self ._main_process = self ._execution_context .processes [0 ]
770- self ._start_processes (self ._execution_context .processes [1 :])
771769
772770 interrupts = 0
773771 forced_sigint = False
774772 try :
773+ self ._start_processes (self ._execution_context .processes [1 :])
774+ self ._started = True
775775 self ._main_process .process (self ._loop )
776776 self ._join_spawned_processes ()
777777 logger .info ("All processes exited normally" )
You can’t perform that action at this time.
0 commit comments