Optimize the display of task process bar (#3264)

* Optimize the display of task process bar

* Remove unnecessary metrics initialization in ray communication

* Pin pandas version

mars/deploy/oscar/session.py

@@ -1571,7 +1571,11 @@ def __init__(self, show_progress):
                 else:
                     self.progress_bar = None
             else:
-                self.progress_bar = tqdm(total=100)
+                self.progress_bar = tqdm(
+                    total=100,
+                    bar_format="{l_bar}{bar}| {n:6.2f}/{total_fmt} "
+                    "[{elapsed}<{remaining}, {rate_fmt}{postfix}]",
+                )
 
         self.last_progress: float = 0.0
 

mars/oscar/backends/ray/communication.py

@@ -100,12 +100,7 @@ def __reduce__(self):
 
 
 @lazy_import_on_load(ray)
-def _init_ray_metrics():
-    # Note: Must init metrics before using and here initializing metrics
-    # with ray backend.
-    from ....metrics import init_metrics
-
-    init_metrics("ray")
+def _init_ray_serialization_deserialization():
     _ray_serialize = ray.serialization.SerializationContext.serialize
     _ray_deserialize_object = ray.serialization.SerializationContext._deserialize_object
     serialized_bytes_counter = Metrics.counter(

setup.cfg

@@ -27,7 +27,7 @@ include_package_data = True
 packages = find:
 install_requires =
     numpy>=1.14.0
-    pandas>=1.0.0
+    pandas>=1.1.0,<=1.4.4
     scipy>=1.0.0
     scikit-learn>=0.20
     numexpr>=2.6.4