Commit 665c47c1 authored by Konstantinos Poulakakis's avatar Konstantinos Poulakakis
Browse files

Automation: some minor fixes for test_analytics , test_telemetry DB and automationservice yml.

parent 30abab89
Loading
Loading
Loading
Loading
+2 −2
Original line number Diff line number Diff line
@@ -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:
+2 −1
Original line number Diff line number Diff line
@@ -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()
+7 −0
Original line number Diff line number Diff line
@@ -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.*
+2 −1
Original line number Diff line number Diff line
@@ -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()