Skip to content

Commit

Permalink
Merge pull request #1290 from asinha94/master
Browse files Browse the repository at this point in the history
Removed warnings filter while encoding integer
  • Loading branch information
lukebakken committed Jan 26, 2021
2 parents cbf32c2 + 96d16f3 commit cc5cfa1
Showing 1 changed file with 8 additions and 11 deletions.
19 changes: 8 additions & 11 deletions pika/data.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@
import struct
import decimal
import calendar
import warnings

from datetime import datetime

Expand Down Expand Up @@ -133,16 +132,14 @@ def encode_value(pieces, value): # pylint: disable=R0911
pieces.append(struct.pack('>cq', b'l', value))
return 9
elif isinstance(value, int):
with warnings.catch_warnings():
warnings.filterwarnings('error')
try:
packed = struct.pack('>ci', b'I', value)
pieces.append(packed)
return 5
except (struct.error, DeprecationWarning):
packed = struct.pack('>cq', b'l', long(value))
pieces.append(packed)
return 9
try:
packed = struct.pack('>ci', b'I', value)
pieces.append(packed)
return 5
except struct.error:
packed = struct.pack('>cq', b'l', long(value))
pieces.append(packed)
return 9
elif isinstance(value, decimal.Decimal):
value = value.normalize()
if value.as_tuple().exponent < 0:
Expand Down

0 comments on commit cc5cfa1

Please sign in to comment.