Merge remote-tracking branch 'origin/fy_spinner' into identify_slow_t…

…ests

deeplake/util/spinner.py

@@ -55,7 +55,6 @@ def run_spinner(spinner):
         yield
     finally:
         if spinner_started:
-            spinner._show_cursor()
             spinner.stop()
             sys.stdout = save_stdout
             sys.stderr = save_stderr
@@ -74,21 +73,25 @@ def __init__(self, *args, **kwargs):
         self.file = sys.stderr
 
     def run(self):
-        time.sleep(deeplake.constants.SPINNER_START_DELAY)
-        frames = cycle("/-\\|")
-        if not self._hide_event.is_set():
-            self._hide_cursor()
-        while not self._stop_event.is_set():
-            if self._hide_event.is_set():
-                time.sleep(0.1)
-                continue
-            with self._stderr_lock:
-                self._clear_line()
-                self.file.write(next(frames))
-                self.file.flush()
-                self._cur_line_len = 1
-
-            self._stop_event.wait(0.1)
+        try:
+            time.sleep(deeplake.constants.SPINNER_START_DELAY)
+            frames = cycle("/-\\|")
+            if not self._hide_event.is_set():
+                self._hide_cursor()
+            while not self._stop_event.is_set():
+                if self._hide_event.is_set():
+                    time.sleep(0.1)
+                    continue
+                with self._stderr_lock:
+                    self._clear_line()
+                    self.file.write(next(frames))
+                    self.file.flush()
+                    self._cur_line_len = 1
+
+                self._stop_event.wait(0.1)
+        except ValueError:
+            # I/O operation on closed file
+            pass
 
     def hide(self):
         if not self._hide_event.is_set():
@@ -106,10 +109,14 @@ def show(self):
                 self._hide_cursor()
 
     def stop(self):
-        self._stop_event.set()
-        if not self._hide_event.is_set():
-            self._clear_line()
-        self._show_cursor()
+        try:
+            self._stop_event.set()
+            if not self._hide_event.is_set():
+                self._clear_line()
+            self._show_cursor()
+        except ValueError:
+            # I/O operation on closed file
+            pass
 
     def _clear_line(self):
         if self.file.isatty():