@@ -623,13 +623,13 @@ def __init__(
623623 self ._dockerCid : Optional [str ] = None
624624 self ._docker_process : Optional [DummyPopen ] = None
625625
626- def _docker_process_get (self ) -> Optional [DummyPopen ]:
626+ def _docker_process_get (self , docker_cid : str ) -> Optional [DummyPopen ]:
627627 if sys .platform == 'win32' :
628628 raise NotImplementedError ("Docker not supported on win32!" )
629629
630630 docker_process = None
631631 for idx in range (0 , 40 ):
632- dockerTop = subprocess .check_output (["docker" , "top" , self . _dockerCid ]).decode ().strip ()
632+ dockerTop = subprocess .check_output (["docker" , "top" , docker_cid ]).decode ().strip ()
633633 docker_process = None
634634 for line in dockerTop .split ("\n " ):
635635 columns = line .split ()
@@ -838,7 +838,7 @@ def _docker_omc_start(self) -> Tuple[subprocess.Popen, DummyPopen, str]:
838838 raise OMCSessionException (f"Docker did not start (timeout={ self ._timeout } might be too short "
839839 "especially if you did not docker pull the image before this command)." )
840840
841- docker_process = self ._docker_process_get ()
841+ docker_process = self ._docker_process_get (docker_cid = docker_cid )
842842 if docker_process is None :
843843 raise OMCSessionException (f"Docker top did not contain omc process { self ._random_string } . "
844844 f"Log-file says:\n { self .get_log ()} " )
@@ -926,7 +926,7 @@ def _docker_omc_start(self) -> Tuple[subprocess.Popen, DummyPopen]:
926926
927927 docker_process = None
928928 if isinstance (self ._dockerCid , str ):
929- docker_process = self ._docker_process_get ()
929+ docker_process = self ._docker_process_get (docker_cid = self . _dockerCid )
930930
931931 if docker_process is None :
932932 raise OMCSessionException (f"Docker top did not contain omc process { self ._random_string } "
0 commit comments