From 8ecddb9c6728e7a3e1aaf4c1a5acde5db513a9aa Mon Sep 17 00:00:00 2001 From: lasanthaS Date: Tue, 8 Oct 2019 17:04:20 +0530 Subject: [PATCH 1/2] Bump Siddhi version --- __PySiddhiProxy/pom.xml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/__PySiddhiProxy/pom.xml b/__PySiddhiProxy/pom.xml index 86ea9bb..0c635f0 100644 --- a/__PySiddhiProxy/pom.xml +++ b/__PySiddhiProxy/pom.xml @@ -30,7 +30,7 @@ io.siddhi siddhi-core - 5.1.5 + 5.1.7 @@ -224,4 +224,4 @@ - \ No newline at end of file + From 951d0db30cbcf067f59f11e59d9fcb4843da9d94 Mon Sep 17 00:00:00 2001 From: lasanthaS Date: Tue, 8 Oct 2019 17:04:39 +0530 Subject: [PATCH 2/2] Fix TestOutputStream test --- Tests/SiddhiCoreTests/TestOutputStream.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Tests/SiddhiCoreTests/TestOutputStream.py b/Tests/SiddhiCoreTests/TestOutputStream.py index 736ad2f..cfda7dd 100644 --- a/Tests/SiddhiCoreTests/TestOutputStream.py +++ b/Tests/SiddhiCoreTests/TestOutputStream.py @@ -44,8 +44,7 @@ def getCount(self, event): def test_outputstram(self): logging.info("OutputStream Test 1: Test reception of events") siddhiManager = SiddhiManager() - cseEventStream = "@config(async = 'true') " \ - "define stream cseEventStream (symbol string, price float, volume int);" + cseEventStream = "define stream cseEventStream (symbol string, price float, volume int);" query = "@info(name = 'query 1') from cseEventStream select symbol, price, volume insert into OutputStream; " @@ -58,6 +57,7 @@ def receive(self, events): _self_shaddow.inEventCount.addAndGet(len(events)) siddhiAppRuntime.addCallback("OutputStream", StreamCallbackImpl()) + siddhiAppRuntime.start() inputHandler = siddhiAppRuntime.getInputHandler("cseEventStream")