|
14 | 14 | Most useful definitions and typings will be found in the service_definitions module. |
15 | 15 | """ |
16 | 16 |
|
17 | | -from __future__ import annotations |
18 | | - |
19 | 17 | import time |
20 | 18 | from collections import defaultdict |
21 | 19 | from threading import Lock |
22 | 20 | from types import MappingProxyType |
23 | | -from typing import TYPE_CHECKING, Any, Literal |
| 21 | +from typing import Any, Literal |
24 | 22 | from uuid import UUID, uuid1, uuid3, uuid4 |
25 | 23 |
|
26 | 24 | from pydantic import ConfigDict, ValidationError, validate_call |
|
32 | 30 | ) |
33 | 31 | from ._internal.data_plane.data_plane_manager import DataPlaneManager |
34 | 32 | from ._internal.exceptions import IntersectApplicationError, IntersectError |
| 33 | +from ._internal.function_metadata import FunctionMetadata |
35 | 34 | from ._internal.generic_serializer import GENERIC_MESSAGE_SERIALIZER |
36 | 35 | from ._internal.interfaces import IntersectEventObserver |
37 | 36 | from ._internal.logger import logger |
|
68 | 67 | ) |
69 | 68 | from .version import version_string |
70 | 69 |
|
71 | | -if TYPE_CHECKING: |
72 | | - from ._internal.function_metadata import FunctionMetadata |
73 | | - |
74 | 70 |
|
75 | 71 | @final |
76 | 72 | class IntersectService(IntersectEventObserver): |
@@ -686,7 +682,7 @@ def _process_external_requests(self) -> None: |
686 | 682 | del extreq |
687 | 683 | self._external_requests_lock.release_lock() |
688 | 684 |
|
689 | | - def _process_external_request(self, extreq: IntersectService._ExternalRequest) -> None: |
| 685 | + def _process_external_request(self, extreq: _ExternalRequest) -> None: |
690 | 686 | if extreq.request_state == 'unhandled': |
691 | 687 | # use temporary intermediate state to avoid sending message twice |
692 | 688 | extreq.request_state = 'sending' |
|
0 commit comments