Skip to content

Commit bd86c14

Browse files
committed
Merge pull request #104 from tvincentNuoDB/master
Updated putOpaque to avoid bytes typing
2 parents 9d5f1cc + 0291a13 commit bd86c14

File tree

2 files changed

+9
-6
lines changed

2 files changed

+9
-6
lines changed

pynuodb/encodedsession.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -445,12 +445,12 @@ def putOpaque(self, value):
445445
"""Appends an Opaque data value to the message."""
446446
data = value.string
447447
length = len(data)
448+
if systemVersion is '3' and type(value) is bytes:
449+
data = data.decode('latin-1')
448450
if length < 40:
449451
packed = chr(protocol.OPAQUELEN0 + length) + data
450452
else:
451453
lengthStr = toByteString(length)
452-
if systemVersion is '3':
453-
data = data.decode('latin-1')
454454
packed = chr(protocol.OPAQUECOUNT1 - 1 + len(lengthStr)) + lengthStr + data
455455
self.__output += packed
456456
return self

pynuodb/entity.py

Lines changed: 7 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,8 @@ def find_peer(self, address, port=None):
142142
inet_sock_addr = ":".join([ip, str(port)])
143143
try:
144144
return self.__peers_by_addr[inet_sock_addr]
145-
except:
145+
except Exception as exception:
146+
print(exception.message)
146147
pass
147148

148149
session = Session(address, port=port, service="Identity")
@@ -156,7 +157,8 @@ def find_peer(self, address, port=None):
156157
if peer:
157158
self.__peers_by_addr[peer._get_normalized_addr()] = peer
158159
return peer
159-
except:
160+
except Exception as exception:
161+
print(exception.message)
160162
return None
161163

162164
def get_peer(self, agent_id):
@@ -746,7 +748,8 @@ def _remove_process(self, process):
746748
"""
747749
try:
748750
del self.__processes[process.pid]
749-
except:
751+
except Exception as exception:
752+
print(exception.message)
750753
pass
751754

752755
def _get_normalized_addr(self):
@@ -1222,7 +1225,7 @@ def requirements(self):
12221225
return self._requirements
12231226

12241227

1225-
class Description:
1228+
class Description(object):
12261229
success_message = "Success"
12271230

12281231
@staticmethod

0 commit comments

Comments
 (0)