manifests/automationservice.yaml

@@ -41,8 +41,8 @@ spec:
             - name: LOG_LEVEL
               value: "INFO"
           envFrom:
-            - secretRef:
-                name: crdb-analytics
+#            - secretRef:
+#                name: crdb-analytics
             - secretRef:
                 name: kfk-kpi-data
           startupProbe:

src/analytics/tests/test_analytics_db.py

@@ -15,12 +15,13 @@
 
 import logging
 from analytics.database.Analyzer_DB import AnalyzerDB
+from analytics.database.AnalyzerModel import Analyzer as AnalyzerModel
 
 LOGGER = logging.getLogger(__name__)
 
 def test_verify_databases_and_tables():
     LOGGER.info('>>> test_verify_databases_and_tables : START <<< ')
-    AnalyzerDBobj = AnalyzerDB()
+    AnalyzerDBobj = AnalyzerDB(AnalyzerModel)
     # AnalyzerDBobj.drop_database()
     # AnalyzerDBobj.verify_tables()
     AnalyzerDBobj.create_database()

src/automation/requirements.in

@@ -11,3 +11,10 @@
 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 # See the License for the specific language governing permissions and
 # limitations under the License.
+
+apscheduler==3.10.4
+confluent-kafka==2.3.*
+psycopg2-binary==2.9.*
+SQLAlchemy==1.4.*
+sqlalchemy-cockroachdb==1.4.*
+SQLAlchemy-Utils==0.38.*

src/policy/src/main/java/org/etsi/tfs/policy/policy/CommonPolicyServiceImpl.java

@@ -117,7 +117,7 @@ public class CommonPolicyServiceImpl {
     }
 
     public void applyActionServiceBasedOnKpiId(String kpiId) {
-        if (!kpiPolicyRuleServiceMap.contains(kpiId)) {
+        if (!kpiPolicyRuleServiceMap.containsKey(kpiId)) {
             LOGGER.info("No Policy for KpiId");
             return;
         }

src/policy/src/main/resources/application.yml

@@ -72,6 +72,14 @@ quarkus:
         cpu: 500m
         memory: 2048Mi
 
+#Disable Kafka on Test
+"%test":
+  mp:
+    messaging:
+      connector:
+        smallrye-kafka:
+          enabled: false
+
 mp:
   messaging:
     incoming:

src/telemetry/tests/test_telemetryDB.py

@@ -15,12 +15,13 @@
 
 import logging
 from telemetry.database.Telemetry_DB import TelemetryDB
+from telemetry.database.TelemetryModel import Collector as CollectorModel
 
 LOGGER = logging.getLogger(__name__)
 
 def test_verify_databases_and_tables():
     LOGGER.info('>>> test_verify_databases_and_tables : START <<< ')
-    TelemetryDBobj = TelemetryDB()
+    TelemetryDBobj = TelemetryDB(CollectorModel)
     # TelemetryDBobj.drop_database()
     # TelemetryDBobj.verify_tables()
     TelemetryDBobj.create_database()