keyboard_interrupt method is now public; prepared for release

waikato-datamining · Dec 10, 2020 · 05c160c · 05c160c
1 parent d98d9d6
commit 05c160c
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 6 deletions.
diff --git a/CHANGES.rst b/CHANGES.rst
@@ -1,6 +1,12 @@
 Changelog
 =========
 
+0.0.7 (2020-12-10)
+------------------
+
+- `keyboard_interrupt` method is now public
+
+
 0.0.6 (2020-12-10)
 ------------------
 

diff --git a/setup.py b/setup.py
@@ -38,7 +38,7 @@ def _read(f):
     install_requires=[
         "watchdog",
     ],
-    version="0.0.6",
+    version="0.0.7",
     author='Peter Reutemann',
     author_email='fracpete@waikato.ac.nz',
 )
diff --git a/src/sfp/_poller.py b/src/sfp/_poller.py
@@ -292,7 +292,7 @@ def _log(self, type, *args):
             else:
                 self._logging(type, *args)
 
-    def _keyboard_interrupt(self):
+    def keyboard_interrupt(self):
         """
         Prints an error message and stops the polling.
         """
@@ -431,7 +431,7 @@ def list_files(self):
                                     self.error("Flagged as incomplete %d times, skipping" % self.blacklist_tries)
                                     os.rename(k, os.path.join(self.output_dir, os.path.basename(k)))
                             except KeyboardInterrupt:
-                                self._keyboard_interrupt()
+                                self.keyboard_interrupt()
                                 return
                             except:
                                 self.error(traceback.format_exc())
@@ -448,7 +448,7 @@ def list_files(self):
             self.debug("Finished listing files")
 
         except KeyboardInterrupt:
-            self._keyboard_interrupt()
+            self.keyboard_interrupt()
             return
         except:
             self.error("Failed listing files!")
@@ -510,7 +510,7 @@ def process_files(self, file_list: List[str]):
                                     self.debug("Moving other input %s to %s" % (other_path, self.output_dir))
                                     os.rename(other_path, os.path.join(self.output_dir, os.path.basename(other_path)))
                 except KeyboardInterrupt:
-                    self._keyboard_interrupt()
+                    self.keyboard_interrupt()
                     return
                 except:
                     self.error("Failed processing: %s" % file_path)
@@ -522,7 +522,7 @@ def process_files(self, file_list: List[str]):
                 self.info("Finished processing: %d ms" % processing_time)
 
         except KeyboardInterrupt:
-            self._keyboard_interrupt()
+            self.keyboard_interrupt()
             return
         except:
             self.error("Failed processing files!")