add prefix option to progress, add scheduler arg in from_pandas

rxsci/internal/utils.py

@@ -57,5 +57,7 @@ def build_tdqm_kwargs(progress):
         if 'interval' in progress:
             tqdm_kwargs['mininterval'] = progress['interval']
             tqdm_kwargs['maxinterval'] = progress['interval']
+        if 'prefix' in progress:
+            tqdm_kwargs['desc'] = progress['prefix']
 
     return tqdm_kwargs

rxsci/operators/from_iterable.py

@@ -13,6 +13,10 @@
 def from_iterable(iterable, scheduler=None, progress=False):
     """Converts an iterable to an observable.
 
+    When a dict is provided as the progress argument, it accepts these keys:
+    interval: The interval in seconds used to update the progressbar
+    prefix: A prefix displayed at before the progressbar.
+
     Args:
         iterable: A Python iterable
         scheduler: An optional scheduler to schedule the values on.

rxsci/operators/pandas.py

@@ -10,11 +10,16 @@
     except Exception:
         pass
 
-    def from_pandas(dataframe, progress=False):
+    def from_pandas(dataframe, scheduler=None, progress=False):
         """Creates an observable from a pandas dataframe
 
+        When a dict is provided as the progress argument, it accepts these keys:
+        interval: The interval in seconds used to update the progressbar
+        prefix: A prefix displayed at before the progressbar.
+
         Args:
             dataframe: A pandas dataframe
+            scheduler: An optional scheduler to schedule the values on.
             progess: Displays a progressbar while iterating the dataframe
 
         Returns:
@@ -25,8 +30,14 @@ def from_pandas(dataframe, progress=False):
             if 'total' not in tqdm_kwargs:
                 tqdm_kwargs['total']=len(dataframe)
 
-            return rx.from_(tqdm(dataframe.itertuples(index=False), **tqdm_kwargs))
-        return rx.from_(dataframe.itertuples(index=False))
+            return rx.from_(
+                tqdm(dataframe.itertuples(index=False), **tqdm_kwargs),
+                scheduler=scheduler,
+            )
+        return rx.from_(
+            dataframe.itertuples(index=False),
+            scheduler=scheduler,
+        )
 
 
     def to_pandas(columns=None):

tests/operators/test_from_iterable.py

@@ -5,7 +5,10 @@
 @pytest.mark.parametrize(
     "progress",
     [
-        False, True, {'interval': 60}
+        False, True,
+        {'interval': 60},
+        {'prefix': 'test_from'},
+        {'prefix': 'test_from', 'interval': 60}
     ]
 )
 def test_from_iterable_base(progress):