Tweak runners (#246)

This commit ...
1. applies some formal changes
2. assigns `finished` flag of DeferedTestRunner within `_stop_testing()` method.

Author: deathaxe

unittesting.json

@@ -1,6 +1,6 @@
 // do not copy
 {
-    "coverage_on_worker_thread": true,
+	"coverage_on_worker_thread": true,
 	"reload_package_on_testing": false,
 	"show_reload_progress": false,
 }

unittesting/core/py33/case.py

@@ -1,7 +1,7 @@
-from functools import wraps
 import sys
 import unittest
 import warnings
+from functools import wraps
 from unittest.case import _ExpectedFailure, _UnexpectedSuccess, SkipTest, _Outcome
 from ...utils import isiterable
 

unittesting/core/py33/runner.py

@@ -1,14 +1,9 @@
-from functools import partial
+import sublime
 import time
-from unittest.runner import TextTestRunner, registerResult
 import warnings
-import sublime
-
-
-def defer(delay, callback, *args, **kwargs):
-    # Rely on late binding in case a user patches it
-    sublime.set_timeout(partial(callback, *args, **kwargs), delay)
 
+from functools import partial
+from unittest.runner import TextTestRunner, registerResult
 
 DEFAULT_CONDITION_POLL_TIME = 17
 DEFAULT_CONDITION_TIMEOUT = 4000
@@ -18,6 +13,11 @@ def defer(delay, callback, *args, **kwargs):
 run_on_worker = sublime.set_timeout_async
 
 
+def defer(delay, callback, *args, **kwargs):
+    # Rely on late binding in case a user patches it
+    sublime.set_timeout(partial(callback, *args, **kwargs), delay)
+
+
 class DeferringTextTestRunner(TextTestRunner):
     """This test runner runs tests in deferred slices."""
 
@@ -59,7 +59,8 @@ def _start_testing():
                         warnings.filterwarnings(
                             'module',
                             category=DeprecationWarning,
-                            message='Please use assert\\w+ instead.')
+                            message='Please use assert\\w+ instead.'
+                        )
                 startTestRun = getattr(result, 'startTestRun', None)
                 if startTestRun is not None:
                     startTestRun()
@@ -86,21 +87,19 @@ def _continue_testing(deferred, send_value=None, throw_value=None):
                 elif isinstance(condition, int):
                     defer(condition, _continue_testing, deferred)
                 elif condition == AWAIT_WORKER:
-                    run_on_worker(
-                        partial(defer, 0, _continue_testing, deferred)
-                    )
+                    run_on_worker(partial(defer, 0, _continue_testing, deferred))
                 else:
                     defer(0, _continue_testing, deferred)
 
             except StopIteration:
                 _stop_testing()
-                self.finished = True
 
             except Exception as e:
                 _handle_error(e)
 
         def _wait_condition(
-            deferred, condition,
+            deferred,
+            condition,
             period=DEFAULT_CONDITION_POLL_TIME,
             timeout=self.condition_timeout,
             start_time=None
@@ -179,4 +178,6 @@ def _stop_testing():
             else:
                 self.stream.write("\n")
 
+            self.finished = True
+
         _start_testing()

unittesting/core/py38/runner.py

@@ -1,14 +1,9 @@
-from functools import partial
+import sublime
 import time
-from unittest.runner import TextTestRunner, registerResult
 import warnings
-import sublime
-
-
-def defer(delay, callback, *args, **kwargs):
-    # Rely on late binding in case a user patches it
-    sublime.set_timeout(partial(callback, *args, **kwargs), delay)
 
+from functools import partial
+from unittest.runner import TextTestRunner, registerResult
 
 DEFAULT_CONDITION_POLL_TIME = 17
 DEFAULT_CONDITION_TIMEOUT = 4000
@@ -18,6 +13,11 @@ def defer(delay, callback, *args, **kwargs):
 run_on_worker = sublime.set_timeout_async
 
 
+def defer(delay, callback, *args, **kwargs):
+    # Rely on late binding in case a user patches it
+    sublime.set_timeout(partial(callback, *args, **kwargs), delay)
+
+
 class DeferringTextTestRunner(TextTestRunner):
     """This test runner runs tests in deferred slices."""
 
@@ -59,9 +59,11 @@ def _start_testing():
                     # noisy.  The -Wd and -Wa flags can be used to bypass this
                     # only when self.warnings is None.
                     if self.warnings in ['default', 'always']:
-                        warnings.filterwarnings('module',
-                                                category=DeprecationWarning,
-                                                message=r'Please use assert\w+ instead.')
+                        warnings.filterwarnings(
+                            'module',
+                            category=DeprecationWarning,
+                            message=r'Please use assert\w+ instead.'
+                        )
                 startTestRun = getattr(result, 'startTestRun', None)
                 if startTestRun is not None:
                     startTestRun()
@@ -87,21 +89,19 @@ def _continue_testing(deferred, send_value=None, throw_value=None):
                 elif isinstance(condition, int):
                     defer(condition, _continue_testing, deferred)
                 elif condition == AWAIT_WORKER:
-                    run_on_worker(
-                        partial(defer, 0, _continue_testing, deferred)
-                    )
+                    run_on_worker(partial(defer, 0, _continue_testing, deferred))
                 else:
                     defer(0, _continue_testing, deferred)
 
             except StopIteration:
                 _stop_testing()
-                self.finished = True
 
             except Exception as e:
                 _handle_error(e)
 
         def _wait_condition(
-            deferred, condition,
+            deferred,
+            condition,
             period=DEFAULT_CONDITION_POLL_TIME,
             timeout=self.condition_timeout,
             start_time=None
@@ -180,4 +180,6 @@ def _stop_testing():
             else:
                 self.stream.write("\n")
 
+            self.finished = True
+
         _start_testing()