the progressbar is now passed as an extra argument to wait_interactive

Author: cphyc

ipyparallel/client/asyncresult.py

@@ -28,13 +28,6 @@
 
 from .futures import MessageFuture
 
-try:
-    from tqdm import tqdm
-    use_progressbar = True
-except ImportError:
-    use_progressbar = False
-
-
 def _raw_text(s):
     display_pretty(s, raw=True)
 
@@ -498,14 +491,18 @@ def wall_time(self):
         """
         return self.timedelta(self.submitted, self.received)
 
-    def wait_interactive(self, interval=1., timeout=-1):
-        """interactive wait, printing progress at regular intervals"""
+    def wait_interactive(self, interval=1., timeout=-1, progress=None):
+        """interactive wait, printing progress at regular intervals.
+
+        progress can be a tqdm-like progress bar."""
+
+        use_progressbar = progress is not None
         if timeout is None:
             timeout = -1
         N = len(self)
         tic = time.time()
         if use_progressbar:
-            progress_bar = tqdm(total=N)
+            progress_bar = progress(total=N)
             n_prev = 0
         while not self.ready() and (timeout < 0 or time.time() - tic <= timeout):
             self.wait(interval)