diff --git a/tests/utils.py b/tests/utils.py
index 850667f3c..3bafa0df3 100644
--- a/tests/utils.py
+++ b/tests/utils.py
@@ -472,8 +472,13 @@ class LightningNode(object):
 
     def subd_pid(self, subd):
         """Get the process id of the given subdaemon, eg channeld or gossipd"""
-        pidline = self.daemon.is_in_log('lightning_{}.*: pid [0-9]*,'.format(subd))
-        return re.search(r'pid ([0-9]*),', pidline).group(1)
+        ex = re.compile(r'lightning_{}.*: pid ([0-9]*),'.format(subd))
+        # Make sure we get latest one if it's restarted!
+        for l in reversed(self.daemon.logs):
+            group = ex.search(l)
+            if group:
+                return group.group(1)
+        raise ValueError("No daemon {} found".format(subd))
 
     def is_channel_active(self, chanid):
         channels = self.rpc.listchannels()['channels']