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