Drop run

docs/index.rst

@@ -145,7 +145,7 @@ and use the ``run_in_actor()`` method:
 
 What's going on?
 
-- an initial *actor* is started with ``tractor.run()`` and told to execute
+- an initial *actor* is started with ``trio.run()`` and told to execute
  its main task_: ``main()``
 
 - inside ``main()`` an actor is *spawned* using an ``ActorNusery`` and is told
@@ -182,7 +182,7 @@ Here is a similar example using the latter method:
 
 .. literalinclude:: ../examples/actor_spawning_and_causality_with_daemon.py
 
-The ``rpc_module_paths`` `kwarg` above is a list of module path
+The ``enable_modules`` `kwarg` above is a list of module path
 strings that will be loaded and made accessible for execution in the
 remote actor through a call to ``Portal.run()``. For now this is
 a simple mechanism to restrict the functionality of the remote
@@ -458,7 +458,7 @@ find an actor's socket address by name use the ``find_actor()`` function:
 .. literalinclude:: ../examples/service_discovery.py
 
 The ``name`` value you should pass to ``find_actor()`` is the one you passed as the
-*first* argument to either ``tractor.run()`` or ``ActorNursery.start_actor()``.
+*first* argument to either ``trio.run()`` or ``ActorNursery.start_actor()``.
 
 
 Running actors standalone
@@ -472,15 +472,25 @@ need to hop into a debugger. You just need to pass the existing
 
 .. code:: python
 
- tractor.run(main, arbiter_addr=('192.168.0.10', 1616))
+ import trio
+ import tractor
+
+ async def main():
+
+ async with tractor.open_root_actor(
+ arbiter_addr=('192.168.0.10', 1616)
+ ):
+ await trio.sleep_forever()
+
+ trio.run(main)
 
 
 Choosing a process spawning backend
 ***********************************
 ``tractor`` is architected to support multiple actor (sub-process)
 spawning backends. Specific defaults are chosen based on your system
 but you can also explicitly select a backend of choice at startup
-via a ``start_method`` kwarg to ``tractor.run()``.
+via a ``start_method`` kwarg to ``tractor.open_nursery()``.
 
 Currently the options available are:
 
@@ -536,13 +546,14 @@ main python module of the program:
 .. code:: python
 
  # application/__main__.py
+ import trio
  import tractor
  import multiprocessing
  from . import tractor_app
 
  if __name__ == '__main__':
  multiprocessing.freeze_support()
- tractor.run(tractor_app.main)
+ trio.run(tractor_app.main)
 
 And execute as::
 

examples/__main__.py

@@ -16,4 +16,4 @@
  # temporary dir and name it test_example.py. We import that script
  # module here and invoke it's ``main()``.
  from . import test_example
- test_example.tractor.run(test_example.main, start_method='spawn')
+ test_example.trio.run(test_example.main)

examples/a_trynamic_first_scene.py

@@ -1,3 +1,4 @@
+import trio
 import tractor
 
 _this_module = __name__
@@ -40,4 +41,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main)
+ trio.run(main)

examples/actor_spawning_and_causality.py

@@ -1,3 +1,4 @@
+import trio
 import tractor
 
 
@@ -23,4 +24,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main)
+ trio.run(main)

examples/actor_spawning_and_causality_with_daemon.py

@@ -1,3 +1,4 @@
+import trio
 import tractor
 
 
@@ -16,7 +17,7 @@ async def main():
  portal = await n.start_actor(
  'frank',
  # enable the actor to run funcs from this current module
- rpc_module_paths=[__name__],
+ enable_modules=[__name__],
  )
 
  print(await portal.run(movie_theatre_question))
@@ -30,4 +31,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main)
+ trio.run(main)

examples/asynchronous_generators.py

@@ -14,12 +14,15 @@ async def stream_forever():
 
 
 async def main():
+
  # stream for at most 1 seconds
  with trio.move_on_after(1) as cancel_scope:
+
  async with tractor.open_nursery() as n:
+
  portal = await n.start_actor(
- f'donny',
- rpc_module_paths=[__name__],
+ 'donny',
+ enable_modules=[__name__],
  )
 
  # this async for loop streams values from the above
@@ -34,4 +37,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main)
+ trio.run(main)

examples/debugging/multi_daemon_subactors.py

@@ -11,7 +11,7 @@ async def breakpoint_forever():
 
 async def name_error():
  "Raise a ``NameError``"
- getattr(doggypants)
+ getattr(doggypants) # noqa
 
 
 async def main():

examples/debugging/multi_nested_subactors_error_up_through_nurseries.py

@@ -4,7 +4,7 @@
 
 async def name_error():
  "Raise a ``NameError``"
- getattr(doggypants)
+ getattr(doggypants) # noqa
 
 
 async def breakpoint_forever():

examples/debugging/multi_subactor_root_errors.py

@@ -1,9 +1,10 @@
+import trio
 import tractor
 
 
 async def name_error():
  "Raise a ``NameError``"
- getattr(doggypants)
+ getattr(doggypants) # noqa
 
 
 async def spawn_error():
@@ -32,7 +33,9 @@ async def main():
  - root actor should then fail on assert
  - program termination
  """
- async with tractor.open_nursery() as n:
+ async with tractor.open_nursery(
+ debug_mode=True,
+ ) as n:
 
  # spawn both actors
  portal = await n.run_in_actor(
@@ -54,4 +57,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/debugging/multi_subactors.py

@@ -11,7 +11,7 @@ async def breakpoint_forever():
 
 async def name_error():
  "Raise a ``NameError``"
- getattr(doggypants)
+ getattr(doggypants) # noqa
 
 
 async def spawn_error():
@@ -36,7 +36,9 @@ async def main():
  `-python -m tractor._child --uid ('spawn_error', '52ee14a5 ...)
  `-python -m tractor._child --uid ('name_error', '3391222c ...)
  """
- async with tractor.open_nursery() as n:
+ async with tractor.open_nursery(
+ debug_mode=True,
+ ) as n:
 
  # Spawn both actors, don't bother with collecting results
  # (would result in a different debugger outcome due to parent's
@@ -47,4 +49,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/debugging/root_actor_breakpoint.py

@@ -4,12 +4,16 @@
 
 async def main():
 
- await trio.sleep(0.1)
+ async with tractor.open_root_actor(
+ debug_mode=True,
+ ):
 
- await tractor.breakpoint()
+  await trio.sleep(0.1)
 
- await trio.sleep(0.1)
+ await tractor.breakpoint()
+
+ await trio.sleep(0.1)
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/debugging/root_actor_breakpoint_forever.py

@@ -1,11 +1,15 @@
+import trio
 import tractor
 
 
 async def main():
 
- while True:
- await tractor.breakpoint()
+ async with tractor.open_root_actor(
+ debug_mode=True,
+ ):
+ while True:
+ await tractor.breakpoint()
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/debugging/root_actor_error.py

@@ -1,9 +1,13 @@
+import trio
 import tractor
 
 
 async def main():
- assert 0
+ async with tractor.open_root_actor(
+ debug_mode=True,
+ ):
+ assert 0
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/debugging/root_cancelled_but_child_is_in_tty_lock.py

@@ -1,9 +1,10 @@
+import trio
 import tractor
 
 
 async def name_error():
  "Raise a ``NameError``"
- getattr(doggypants)
+ getattr(doggypants) # noqa
 
 
 async def spawn_until(depth=0):
@@ -37,7 +38,10 @@ async def main():
  └─ python -m tractor._child --uid ('name_error', '6c2733b8 ...)
 
  """
- async with tractor.open_nursery() as n:
+ async with tractor.open_nursery(
+ debug_mode=True,
+ loglevel='warning'
+ ) as n:
 
  # spawn both actors
  portal = await n.run_in_actor(
@@ -58,4 +62,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True, loglevel='warning')
+ trio.run(main)

examples/debugging/subactor_breakpoint.py

@@ -12,7 +12,9 @@ async def breakpoint_forever():
 
 async def main():
 
- async with tractor.open_nursery() as n:
+ async with tractor.open_nursery(
+ debug_mode=True,
+ ) as n:
 
  portal = await n.run_in_actor(
  breakpoint_forever,
@@ -21,4 +23,4 @@ async def main():
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True, loglevel='debug')
+ trio.run(main)

examples/debugging/subactor_error.py

@@ -1,3 +1,4 @@
+import trio
 import tractor
 
 
@@ -6,11 +7,13 @@ async def name_error():
 
 
 async def main():
- async with tractor.open_nursery() as n:
+ async with tractor.open_nursery(
+ debug_mode=True,
+ ) as n:
 
  portal = await n.run_in_actor(name_error)
  await portal.result()
 
 
 if __name__ == '__main__':
- tractor.run(main, debug_mode=True)
+ trio.run(main)

examples/full_fledged_streaming_service.py

@@ -68,10 +68,11 @@ async def push_to_chan(portal, send_chan):
 # this is the main actor and *arbiter*
 async def main():
  # a nursery which spawns "actors"
- async with tractor.open_nursery() as nursery:
+ async with tractor.open_nursery(
+ arbiter_addr=('127.0.0.1', 1616)
+ ) as nursery:
 
  seed = int(1e3)
- import time
  pre_start = time.time()
 
  portal = await nursery.start_actor(
@@ -100,4 +101,4 @@ async def main():
 
 
 if __name__ == '__main__':
- final_stream = tractor.run(main, arbiter_addr=('127.0.0.1', 1616))
+ final_stream = trio.run(main)

examples/parallelism/_concurrent_futures_primes.py

@@ -10,6 +10,7 @@
  115797848077099,
  1099726899285419]
 
+
 def is_prime(n):
  if n < 2:
  return False
@@ -24,6 +25,7 @@ def is_prime(n):
  return False
  return True
 
+
 def main():
  with concurrent.futures.ProcessPoolExecutor() as executor:
  start = time.time()
@@ -33,6 +35,7 @@ def main():
 
  print(f'processing took {time.time() - start} seconds')
 
+
 if __name__ == '__main__':
 
  start = time.time()

examples/parallelism/concurrent_actors_primes.py

@@ -4,7 +4,7 @@
 
 https://docs.python.org/3/library/concurrent.futures.html#processpoolexecutor-example
 
-This uses no extra threads, fancy semaphores or futures; all we need 
+This uses no extra threads, fancy semaphores or futures; all we need
 is ``tractor``'s channels.
 
 """