X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fadapter%2Fredis_eventpublisher.py;h=4df167e0cdc9939ca86502c0a80f99b8cf774089;hb=d4513e022d7d75d9967072cec1e0d7db34571120;hp=835c72c9992583417bf9ca2c5f5882d13e50e4d8;hpb=81e3575a77366f30c2049f98c48a3087db0ea992;p=pti%2Fo2.git diff --git a/o2ims/adapter/redis_eventpublisher.py b/o2ims/adapter/redis_eventpublisher.py index 835c72c..4df167e 100644 --- a/o2ims/adapter/redis_eventpublisher.py +++ b/o2ims/adapter/redis_eventpublisher.py @@ -13,18 +13,19 @@ # limitations under the License. import json -import logging from dataclasses import asdict import redis from o2ims import config from o2ims.domain import events -logger = logging.getLogger(__name__) +from o2common.helper import o2logging +logger = o2logging.get_logger(__name__) + r = redis.Redis(**config.get_redis_host_and_port()) def publish(channel, event: events.Event): - logging.info("publishing: channel=%s, event=%s", channel, event) + logger.info("publishing: channel=%s, event=%s", channel, event) r.publish(channel, json.dumps(asdict(event)))