watch_tube() belongs to the beanstalk module

Signed-off-by: Zack Cerza <zack.cerza@inktank.com>

diff --git a/teuthology/worker.py b/teuthology/worker.py
index 97ef40d10bd9c5cb3c0a15e946e07dc5321a5dd8..52337c45044758f5dc2cbe613b8c3a7807415889 100644 (file)
--- a/teuthology/worker.py
+++ b/teuthology/worker.py
@@ -144,7 +144,7 @@ def main(ctx):
     read_config(ctx)
 
     connection = beanstalk.connect()
-    connection.watch_tube(ctx.tube)
+    beanstalk.watch_tube(connection, ctx.tube)
 
     while True:
         if need_restart():