X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Fcore%2Fagent.py;h=1e81141d8fdf31ab38eef0c3fa451810719e2c3f;hb=8d2d6a02f2282c50a934ccab25fc909e3bbc27c6;hp=d637374fc36d7f02b378aab6f3b73569b7b7079d;hpb=16256cbbf6cdfde8debc3254bf55ce0b8fa51b08;p=osm%2FPOL.git

diff --git a/osm_policy_module/core/agent.py b/osm_policy_module/core/agent.py
index d637374..1e81141 100644
--- a/osm_policy_module/core/agent.py
+++ b/osm_policy_module/core/agent.py
@@ -30,7 +30,7 @@ from json import JSONDecodeError
 import yaml
 from aiokafka import AIOKafkaConsumer
 
-from osm_policy_module.common.db_client import DbClient
+from osm_policy_module.common.common_db_client import CommonDbClient
 from osm_policy_module.common.lcm_client import LcmClient
 from osm_policy_module.common.mon_client import MonClient
 from osm_policy_module.core import database
@@ -48,7 +48,7 @@ class PolicyModuleAgent:
         if not loop:
             loop = asyncio.get_event_loop()
         self.loop = loop
-        self.db_client = DbClient()
+        self.db_client = CommonDbClient()
         self.mon_client = MonClient(loop=self.loop)
         self.lcm_client = LcmClient(loop=self.loop)
         self.kafka_server = '{}:{}'.format(cfg.OSMPOL_MESSAGE_HOST,