From f715a0cae81ee4fe554509ecd25e336e5c589a85 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Sun, 17 Jan 2021 13:34:52 -0500
Subject: [PATCH] Remove use of tractor.run()

---
 .../parallelism/concurrent_actors_primes.py   | 25 ++++++++++---------
 1 file changed, 13 insertions(+), 12 deletions(-)

diff --git a/examples/parallelism/concurrent_actors_primes.py b/examples/parallelism/concurrent_actors_primes.py
index 2867fe5..7df2e43 100644
--- a/examples/parallelism/concurrent_actors_primes.py
+++ b/examples/parallelism/concurrent_actors_primes.py
@@ -50,7 +50,14 @@ async def worker_pool(workers=4):
 
     """
 
-    async with tractor.open_nursery() as tn:
+    async with tractor.open_nursery(
+        loglevel='ERROR',
+
+        # uncomment to use ``multiprocessing`` fork server backend
+        # which gives a startup time boost at the expense of nested
+        # processs scalability
+        # start_method='forkserver')
+    ) as tn:
 
         portals = []
         results = []
@@ -62,7 +69,7 @@ async def worker_pool(workers=4):
             portals.append(
                 await tn.start_actor(
                     f'worker_{i}',
-                    rpc_module_paths=[__name__],
+                    enable_modules=[__name__],
                 )
             )
 
@@ -105,15 +112,9 @@ async def main():
 
         print(f'processing took {time.time() - start} seconds')
 
-if __name__ == '__main__':
-    start = time.time()
-    tractor.run(
-        main,
-        loglevel='ERROR',
 
-        # uncomment to use ``multiprocessing`` fork server backend
-        # which gives a startup time boost at the expense of nested
-        # processs scalability
-        # start_method='forkserver')
-    )
+if __name__ == '__main__':
+
+    start = time.time()
+    trio.run(main)
     print(f'script took {time.time() - start} seconds')