@@ -19,10 +19,11 @@ def _sanitize(s):
 
 
 class _RegularPush(threading.Thread):
-    def __init__(self, pusher, interval):
+    def __init__(self, pusher, interval, prefix):
         super(_RegularPush, self).__init__()
         self._pusher = pusher
         self._interval = interval
+        self._prefix = prefix
 
     def run(self):
         wait_until = time.time()
@@ -37,7 +38,7 @@ def run(self):
                 # time.sleep can return early.
                 time.sleep(wait_until - now)
             try:
-                self._pusher.push()
+                self._pusher.push(prefix=self._prefix)
             except IOError:
                 logging.exception("Push failed")
 
@@ -73,7 +74,7 @@ def push(self, prefix=''):
         conn.sendall(''.join(output).encode('ascii'))
         conn.close()
 
-    def start(self, interval=60.0):
-        t = _RegularPush(self, interval)
+    def start(self, interval=60.0, prefix=''):
+        t = _RegularPush(self, interval, prefix)
         t.daemon = True
         t.start()