From a90dde4ec195ed1f61e01708fd302e6e99e428ad Mon Sep 17 00:00:00 2001
From: Lluis Gifre <lluis.gifre@cttc.es>
Date: Wed, 20 Jul 2022 14:41:15 +0000
Subject: [PATCH] DLT component:
- corrected method used to get record from DLT in test script
---
src/dlt/connector/main_test.py | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/src/dlt/connector/main_test.py b/src/dlt/connector/main_test.py
index 632497220..4ad90eb35 100644
--- a/src/dlt/connector/main_test.py
+++ b/src/dlt/connector/main_test.py
@@ -2,7 +2,7 @@
# PYTHONPATH=/home/cttc/teraflow/src python -m dlt.connector.main_test
import logging, sys, time
-from common.proto.dlt_gateway_pb2 import DLTRECORDOPERATION_ADD, DLTRECORDTYPE_DEVICE, DltRecord
+from common.proto.dlt_gateway_pb2 import DLTRECORDOPERATION_ADD, DLTRECORDOPERATION_UPDATE, DLTRECORDTYPE_DEVICE, DltRecord
from common.tools.object_factory.Device import json_device
from common.tools.grpc.Tools import grpc_message_to_json_string
from src.common.proto.context_pb2 import DEVICEOPERATIONALSTATUS_ENABLED, Device
@@ -33,7 +33,7 @@ def main():
dlt2r_req = r2dlt_req.record_id
LOGGER.info('dlt2r_req = {:s}'.format(grpc_message_to_json_string(dlt2r_req)))
- dlt2r_rep = dltgateway_client.RecordToDlt(dlt2r_req)
+ dlt2r_rep = dltgateway_client.GetFromDlt(dlt2r_req)
LOGGER.info('dlt2r_rep = {:s}'.format(grpc_message_to_json_string(dlt2r_rep)))
dltgateway_collector.stop()
--
GitLab