(self,
connection,
query_params,
row_factory=lambda x: x,
**kwargs
)
| 731 | |
| 732 | class QueryRequestLogic: |
| 733 | def __init__(self, |
| 734 | connection, |
| 735 | query_params, |
| 736 | row_factory=lambda x: x, |
| 737 | **kwargs |
| 738 | ): |
| 739 | |
| 740 | self._connection = connection |
| 741 | self._query_params = query_params |
| 742 | self.row_factory = row_factory |
| 743 | self._streaming_result = None |
| 744 | self._started_streaming = False |
| 745 | self._done_streaming = False |
| 746 | self._metadata = None |
| 747 | self._default_serializer = kwargs.pop('default_serializer', DefaultJsonSerializer()) |
| 748 | self._serializer = None |
| 749 | self._streaming_timeout = kwargs.pop('streaming_timeout', None) |
| 750 | self._obs_handler: Optional[ObservableRequestHandler] = kwargs.pop('obs_handler', None) |
| 751 | self._processed_core_span = False |
| 752 | |
| 753 | @property |
| 754 | def params(self) -> Dict[str, Any]: |
nothing calls this directly
no test coverage detected