(self)
| 138 | signal.signal(signal.SIGINT, signal.default_int_handler) |
| 139 | |
| 140 | def _lazy_init(self): |
| 141 | if self._state is _State.CLOSED: |
| 142 | raise RuntimeError("Runner is closed") |
| 143 | if self._state is _State.INITIALIZED: |
| 144 | return |
| 145 | if self._loop_factory is None: |
| 146 | self._loop = events.new_event_loop() |
| 147 | if not self._set_event_loop: |
| 148 | # Call set_event_loop only once to avoid calling |
| 149 | # attach_loop multiple times on child watchers |
| 150 | events.set_event_loop(self._loop) |
| 151 | self._set_event_loop = True |
| 152 | else: |
| 153 | self._loop = self._loop_factory() |
| 154 | if self._debug is not None: |
| 155 | self._loop.set_debug(self._debug) |
| 156 | self._context = contextvars.copy_context() |
| 157 | self._state = _State.INITIALIZED |
| 158 | |
| 159 | def _on_sigint(self, signum, frame, main_task): |
| 160 | self._interrupt_count += 1 |
no test coverage detected