Skip to content

Commit 0e35619

Browse files
authored
Merge pull request #31 from srikiraju/master
Fix for protobuf 3.2
2 parents 3791111 + 9d9ce9d commit 0e35619

10 files changed

Lines changed: 397 additions & 355 deletions

File tree

.travis.yml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,6 @@
11
language: python
22
env:
33
- TOXENV=py26-test
4-
- TOXENV=py26-lint
54
- TOXENV=py27-test
65
- TOXENV=py27-lint
76
- TOXENV=py34-test

riemann_client/client.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@ def emit(self, record):
2626

2727
import riemann_client.riemann_pb2
2828
import riemann_client.transport
29+
import google.protobuf.descriptor
2930

3031

3132
logger = logging.getLogger(__name__)
@@ -152,6 +153,9 @@ def create_dict(event):
152153
value = list(value)
153154
elif descriptor.name == 'attributes':
154155
value = dict(((a.key, a.value) for a in value))
156+
elif descriptor.type == \
157+
google.protobuf.descriptor.FieldDescriptor.TYPE_FLOAT:
158+
value = round(value, 1)
155159
data[descriptor.name] = value
156160

157161
return data

riemann_client/riemann.proto

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
package riemann_client;
12
option java_package = "com.aphyr.riemann";
23
option java_outer_classname = "Proto";
34

riemann_client/riemann_pb2.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,6 @@
55
__all__ = ['Event', 'Msg', 'Query', 'Attribute']
66

77
if sys.version_info >= (3,):
8-
from riemann_client.riemann_pb2_py3 import (Event, Msg, Query, Attribute)
8+
from riemann_client.riemann_py3_pb2 import (Event, Msg, Query, Attribute)
99
else:
10-
from riemann_client.riemann_pb2_py2 import (Event, Msg, Query, Attribute)
10+
from riemann_client.riemann_py2_pb2 import (Event, Msg, Query, Attribute)

riemann_client/riemann_pb2_py2.py

Lines changed: 0 additions & 347 deletions
This file was deleted.

0 commit comments

Comments
 (0)