Return corrected tube_name

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

diff --git a/teuthology/beanstalk.py b/teuthology/beanstalk.py
index 6776300b60c07b265f77e5bbb2c2af97089346da..7bf9698ad2fe595fff83e2517dfa190b7803cdae 100644 (file)
--- a/teuthology/beanstalk.py
+++ b/teuthology/beanstalk.py
@@ -21,11 +21,16 @@ def connect():
 
 
 def watch_tube(connection, tube_name):
+    """
+    Watch a given tube, potentially correcting to 'multi' if necessary. Returns
+    the tube_name that was actually used.
+    """
     if ',' in tube_name:
         log.debug("Correcting tube name to 'multi'")
         tube_name = 'multi'
     connection.watch(tube_name)
     connection.ignore('default')
+    return tube_name
 
 
 def walk_jobs(connection, tube_name, processor, pattern=None):