()
| 144 | |
| 145 | |
| 146 | def _create_future() -> Future: |
| 147 | future = Future() # type: Future |
| 148 | # Fixup asyncio debug info by removing extraneous stack entries |
| 149 | source_traceback = getattr(future, "_source_traceback", ()) |
| 150 | while source_traceback: |
| 151 | # Each traceback entry is equivalent to a |
| 152 | # (filename, self.lineno, self.name, self.line) tuple |
| 153 | filename = source_traceback[-1][0] |
| 154 | if filename == __file__: |
| 155 | del source_traceback[-1] |
| 156 | else: |
| 157 | break |
| 158 | return future |
| 159 | |
| 160 | |
| 161 | def _fake_ctx_run(f: Callable[..., _T], *args: Any, **kw: Any) -> _T: |
no outgoing calls
no test coverage detected