original_docstring: Called by the runner to actually execute the code.
docstring: Called by the runner to actually execute the code.
docstring_tokens: Called by the runner to actually execute the code .
code: async def _run(self, code, data):
          """Called by the runner to actually execute the code."""
          self._logger.debug("Start %r with %r", self._runner._path, self._runner.code)
          async with anyio.create_task_group() as tg:
              self._taskgroup = tg
              async with AsyncExitStack() as stack:
                  self._stack = stack
                  sc = tg.cancel_scope
  
                  self._taskgroup = tg
                  self._runner.scope = sc
                  data["_self"] = self
  
                  oka = getattr(self._runner, "ok_after", 0)
                  if oka > 0:
  
                      async def is_ok(oka):
                          await anyio.sleep(oka)
                          await self.setup_done()
  
                      tg.spawn(is_ok, oka)
                  tg.spawn(self._changed_code, code)
  
                  await self._runner.send_event(ReadyMsg(0))
                  res = code(**data)
                  if code.is_async is not None:
                      res = await res
  
                  sc.cancel()
                  return res
code_tokens: async def _run ( self , code , data ) : self . _logger . debug ( "Start %r with %r" , self . _runner . _path , self . _runner . code ) async with anyio . create_task_group ( ) as tg : self . _taskgroup = tg async with AsyncExitStack ( ) as stack : self . _stack = stack sc = tg . cancel_scope self . _taskgroup = tg self . _runner . scope = sc data [ "_self" ] = self oka = getattr ( self . _runner , "ok_after" , 0 ) if oka > 0 : async def is_ok ( oka ) : await anyio . sleep ( oka ) await self . setup_done ( ) tg . spawn ( is_ok , oka ) tg . spawn ( self . _changed_code , code ) await self . _runner . send_event ( ReadyMsg ( 0 ) ) res = code ( ** data ) if code . is_async is not None : res = await res sc . cancel ( ) return res
short_docstring: Called by the runner to actually execute the code.
short_docstring_tokens: Called by the runner to actually execute the code .
comment: """Called by the runner to actually execute the code."""