Updated connection refs #474
This commit is contained in:
		| @@ -5,6 +5,7 @@ Changelog | |||||||
| Changes in 0.6.X | Changes in 0.6.X | ||||||
| ================ | ================ | ||||||
|  |  | ||||||
|  | - updated replicasetconnection - pop port if exists | ||||||
| - bug fix for unknown connection alias error message | - bug fix for unknown connection alias error message | ||||||
|  |  | ||||||
| Changes in 0.6.3 | Changes in 0.6.3 | ||||||
|   | |||||||
| @@ -105,13 +105,13 @@ def get_connection(alias=DEFAULT_CONNECTION_NAME, reconnect=False): | |||||||
|                 for slave_alias in conn_settings['slaves']: |                 for slave_alias in conn_settings['slaves']: | ||||||
|                     slaves.append(get_connection(slave_alias)) |                     slaves.append(get_connection(slave_alias)) | ||||||
|                 conn_settings['slaves'] = slaves |                 conn_settings['slaves'] = slaves | ||||||
|                 conn_settings.pop('read_preference') |                 conn_settings.pop('read_preference', None) | ||||||
|  |  | ||||||
|         connection_class = Connection |         connection_class = Connection | ||||||
|         if 'replicaSet' in conn_settings: |         if 'replicaSet' in conn_settings: | ||||||
|             conn_settings['hosts_or_uri'] = conn_settings.pop('host', None) |             conn_settings['hosts_or_uri'] = conn_settings.pop('host', None) | ||||||
|             # Discard port since it can't be used on ReplicaSetConnection |             # Discard port since it can't be used on ReplicaSetConnection | ||||||
|             conn_settings.pop('port') |             conn_settings.pop('port', None) | ||||||
|             connection_class = ReplicaSetConnection |             connection_class = ReplicaSetConnection | ||||||
|         try: |         try: | ||||||
|             _connections[alias] = connection_class(**conn_settings) |             _connections[alias] = connection_class(**conn_settings) | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user