(self,
connection,
encoded_query,
row_factory=ViewRow,
**kwargs
)
| 520 | |
| 521 | class ViewRequestLogic: |
| 522 | def __init__(self, |
| 523 | connection, |
| 524 | encoded_query, |
| 525 | row_factory=ViewRow, |
| 526 | **kwargs |
| 527 | ): |
| 528 | |
| 529 | self._connection = connection |
| 530 | self._encoded_query = encoded_query |
| 531 | self.row_factory = row_factory |
| 532 | self._streaming_result = None |
| 533 | self._default_serializer = kwargs.pop('default_serializer', DefaultJsonSerializer()) |
| 534 | self._serializer = None |
| 535 | self._started_streaming = False |
| 536 | self._streaming_timeout = kwargs.pop('streaming_timeout', None) |
| 537 | self._done_streaming = False |
| 538 | self._metadata = None |
| 539 | self._obs_handler: Optional[ObservableRequestHandler] = kwargs.pop('obs_handler', None) |
| 540 | self._processed_core_span = False |
| 541 | |
| 542 | @property |
| 543 | def encoded_query(self) -> Dict[str, Any]: |
nothing calls this directly
no test coverage detected