Tune

python · asvetlov · Mar 24, 2022 · Mar 9, 2022 · Mar 10, 2022 · Mar 10, 2022
commit 7cd5430dccd89da0c2034f2cd9506ea2ff9cd610
@@ -96,12 +96,22 @@ Runner context manager
 
       An optional keyword-only *context* argument allows specifying a
       custom :class:`contextvars.Context` for the *coro* to run in.
-      The runner's context is used if ``None``.
+      The runner's default context is used if ``None``.
+
+   .. method:: close()
 
    .. method:: get_loop()
 
       Return the event loop associated with the runner instance.
 
    .. method:: get_context()
 
-      Return the :class:`contextvars.Context` associated with the runner object.
+      Return the default :class:`contextvars.Context` associated with the runner object.
+
+   .. note::
+
+      :class:`Runner` uses the lazy initialization strategy, its constructor doesn't
+      initialize underlying low-level structures.
+
+      Embedded *loop* and *context* are created at :keyword:`with` body entering or the
+      first call of :meth:`run`, :meth:`get_loop`, or :meth:`get_context`.
@@ -66,6 +66,16 @@ def close(self):
             self._loop = None
             self._state = _State.CLOSED
 
+    def get_context(self):
+        """Return the default associated context."""
+        self._lazy_init()
+        return self._context.copy()
+
+    def get_loop(self):
+        """Return embedded event loop."""
+        self._lazy_init()
+        return self._loop
+
     def run(self, coro, *, context=None):
         """Run a coroutine inside the embedded event loop."""
         if not coroutines.iscoroutine(coro):
@@ -78,15 +88,6 @@ def run(self, coro, *, context=None):
         task = self._loop.create_task(coro, context=context)
         return self._loop.run_until_complete(task)
 
-    def get_loop(self):
-        """Return embedded event loop."""
-        self._lazy_init()
-        return self._loop
-
-    def get_context(self):
-        self._lazy_init()
-        return self._context.copy()
-
     def _lazy_init(self):
         if self._state is _State.CLOSED:
             raise RuntimeError("Runner is closed")