From 4c2b42f141e1501222a284f964eb4303cc4f03aa Mon Sep 17 00:00:00 2001 From: Brinda Santh Date: Thu, 3 Oct 2019 20:02:29 -0400 Subject: Add bi-directional python executor tests Issue-ID: CCSDK-1747 Signed-off-by: Brinda Santh Change-Id: I2e2b974d35d6878418eafe8ece9fcb1d69622a61 --- ms/py-executor/blueprints_grpc/blueprint_processing_server.py | 2 +- ms/py-executor/blueprints_grpc/executor_utils.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'ms/py-executor/blueprints_grpc') diff --git a/ms/py-executor/blueprints_grpc/blueprint_processing_server.py b/ms/py-executor/blueprints_grpc/blueprint_processing_server.py index 0c432d4cd..f1f29a035 100644 --- a/ms/py-executor/blueprints_grpc/blueprint_processing_server.py +++ b/ms/py-executor/blueprints_grpc/blueprint_processing_server.py @@ -46,4 +46,4 @@ class BluePrintProcessingServer(BluePrintProcessing_pb2_grpc.BluePrintProcessing # Get the Dynamic Process Instance based on request instance: AbstractScriptFunction = instance_for_input(self.configuration, request) instance.set_context(context) - return instance.process(request) + yield from instance.process(request) diff --git a/ms/py-executor/blueprints_grpc/executor_utils.py b/ms/py-executor/blueprints_grpc/executor_utils.py index 224e35ef9..44b6d8e87 100644 --- a/ms/py-executor/blueprints_grpc/executor_utils.py +++ b/ms/py-executor/blueprints_grpc/executor_utils.py @@ -29,7 +29,7 @@ logger = logging.getLogger("Utils") def current_time(): ts = time.time() - return datetime.datetime.fromtimestamp(ts).strftime("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'") + return datetime.datetime.fromtimestamp(ts).strftime("%Y-%m-%dT%H:%M:%S.%fZ") def blueprint_id(input: ExecutionServiceInput): -- cgit 1.2.3-korg