diff --git a/src/dlt/connector/main_test.py b/src/dlt/connector/main_test.py index 6324972200c8e21943bf58a4082e4efbdff6e6db..4ad90eb35444b7ba4de00159372e466e8fc68905 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()