@@ -74,13 +74,13 @@ def _construct_run_command(self):
7474 st = ["receptor" ]
7575
7676 if self .controller :
77- st .extend (["--debug" , "- d" , self .data_path , "--node-id" , self .name , "controller" ])
77+ st .extend (["-d" , self .data_path , "--node-id" , self .name , "controller" ])
7878 st .extend ([f"--listen={ self .listen } " ])
7979 else :
8080 peer_string = " " .join (
8181 [f"--peer={ self .topology .nodes [pnode ].listen } " for pnode in self .connections ]
8282 )
83- st .extend (["--debug" , "- d" , self .data_path , "--node-id" , self .name , "node" ])
83+ st .extend (["-d" , self .data_path , "--node-id" , self .name , "node" ])
8484 st .extend ([f"--listen={ self .listen } " , peer_string ])
8585
8686 if self .stats_enable :
@@ -99,6 +99,7 @@ def start(self, wait_for_ports=True):
9999 self .wait_for_ports ()
100100
101101 def wait_for_ports (self ):
102+ print ("waiting for nodes ports" + self .name )
102103 wait_for (net_check , func_args = [self .port , self .hostname , True ], num_sec = 10 )
103104 if self .stats_enable :
104105 wait_for (net_check , func_args = [self .stats_port , self .hostname , True ], num_sec = 10 )
0 commit comments