projects
/
osm
/
common.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
improvements in dbmemory. Change yaml.load to save_load
[osm/common.git]
/
osm_common
/
msgkafka.py
diff --git
a/osm_common/msgkafka.py
b/osm_common/msgkafka.py
index
bc9147d
..
1e22c9f
100644
(file)
--- a/
osm_common/msgkafka.py
+++ b/
osm_common/msgkafka.py
@@
-136,11
+136,12
@@
class MsgKafka(MsgBase):
async for message in self.consumer:
if callback:
async for message in self.consumer:
if callback:
- callback(message.topic, yaml.
load(message.key), yaml.
load(message.value), **kwargs)
+ callback(message.topic, yaml.
safe_load(message.key), yaml.safe_
load(message.value), **kwargs)
elif aiocallback:
elif aiocallback:
- await aiocallback(message.topic, yaml.load(message.key), yaml.load(message.value), **kwargs)
+ await aiocallback(message.topic, yaml.safe_load(message.key), yaml.safe_load(message.value),
+ **kwargs)
else:
else:
- return message.topic, yaml.
load(message.key), yaml.
load(message.value)
+ return message.topic, yaml.
safe_load(message.key), yaml.safe_
load(message.value)
except KafkaError as e:
raise MsgException(str(e))
finally:
except KafkaError as e:
raise MsgException(str(e))
finally: