Raise an error when using cpu_bound with an async function, fix a bug…

… with cpu_bound functions on windows

setup.py

@@ -2,7 +2,7 @@
 
 setup(
     name='unsync',
-    version='1.0',
+    version='1.1',
     packages=['unsync'],
     url='https://github.com/alex-sherman/unsync',
     license='MIT',

test/test_call_ordering.py

@@ -29,6 +29,18 @@ async def long(task):
         with raises(asyncio.InvalidStateError):
             self.assertEqual('faff', long(other).result())
 
+    def test_nested_unsync(self):
+        @unsync
+        async def long():
+            @unsync
+            async def other():
+                await asyncio.sleep(0.1)
+                return 'faff'
+            return other().result()
+
+        with raises(asyncio.InvalidStateError):
+            self.assertEqual('faff', long().result())
+
     def test_nested_blocking_on_result_after_await(self):
         calls = []
 

test/test_process_executor.py

@@ -12,10 +12,9 @@ def cpu_bound(duration):
         faff += 1
     return 'faff'
 
-
-
-@pytest.mark.skip
 class ProcessTests(TestCase):
+    def test_raw_cpu_bound(self):
+        cpu_bound(0.01).result()
     def test_cpu_bound(self):
         @unsync
         async def aggregator(tasks):

unsync/unsync.py

@@ -2,6 +2,7 @@
 import concurrent
 import inspect
 import threading
+import os
 from threading import Thread
 
 
@@ -41,11 +42,13 @@ def __call__(self, *args, **kwargs):
             self._set_func(args[0])
             return self
         if inspect.iscoroutinefunction(self.func):
+            if self.cpu_bound:
+                raise TypeError('The CPU bound unsync function %s may not be async or a coroutine' % self.func.__name__)
             future = self.func(*args, **kwargs)
         else:
             if self.cpu_bound:
                 future = unsync.process_executor.submit(
-                    _multiprocess_target, (self.func.__module__ , self.func.__name__), *args, **kwargs)
+                    _multiprocess_target, (self.func.__module__, self.func.__name__), *args, **kwargs)
             else:
                 future = unsync.thread_executor.submit(self.func, *args, **kwargs)
         return Unfuture(future)
@@ -54,6 +57,9 @@ def __get__(self, instance, owner):
         return lambda *args, **kwargs: self(instance, *args, **kwargs)
 
 def _multiprocess_target(func_name, *args, **kwargs):
+    # On Windows MP turns the main module into __mp_main__ in multiprocess targets
+    if os.name == 'nt' and func_name[0] == '__main__':
+        func_name = ('__mp_main__', func_name[1])
     __import__(func_name[0])
     return unsync.unsync_functions[func_name](*args, **kwargs)