Loading src/dlt/connector/main_test.py +2 −2 Original line number Diff line number Diff line Loading @@ -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 Loading Loading @@ -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() Loading Loading
src/dlt/connector/main_test.py +2 −2 Original line number Diff line number Diff line Loading @@ -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 Loading Loading @@ -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() Loading