+ try:
+ requests.get(url)
+ except:
+ # seems to be stopped
+ pass
+
+ def _wait_for_port(self, ip, port):
+ for i in range(0, 10):
+ s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+ s.settimeout(1) # 1 Second Timeout
+ r = s.connect_ex((ip, port))
+ if r == 0:
+ break # port is open proceed
+ else:
+ logging.warning("Waiting for {}:{} ... ({}/10)".format(ip, port, i + 1))
+ time.sleep(1)