(self)
| 3593 | self._event_schedule_times = {} |
| 3594 | |
| 3595 | def connect(self): |
| 3596 | if self._is_shutdown: |
| 3597 | return |
| 3598 | |
| 3599 | self._protocol_version = self._cluster.protocol_version |
| 3600 | self._set_new_connection(self._reconnect_internal()) |
| 3601 | |
| 3602 | self._cluster.metadata.dbaas = self._connection._product_type == dscloud.DATASTAX_CLOUD_PRODUCT_TYPE |
| 3603 | |
| 3604 | def _set_new_connection(self, conn): |
| 3605 | """ |
nothing calls this directly
no test coverage detected