(self, connection_pool, response_callbacks, transaction, shard_hint)
| 177 | _is_async_client: Literal[False] = False |
| 178 | |
| 179 | def __init__(self, connection_pool, response_callbacks, transaction, shard_hint): |
| 180 | # Copy the client's response_callbacks so search-specific entries |
| 181 | # don't pollute the shared dict. |
| 182 | super().__init__( |
| 183 | connection_pool, dict(response_callbacks), transaction, shard_hint |
| 184 | ) |
| 185 | self._init_module_callbacks() |
| 186 | self._register_module_callbacks() |
| 187 | |
| 188 | def _register_module_callbacks(self): |
| 189 | # Pipeline post-processing matches the pre-migration behavior: |
nothing calls this directly
no test coverage detected