From 951d0db30cbcf067f59f11e59d9fcb4843da9d94 Mon Sep 17 00:00:00 2001 From: lasanthaS Date: Tue, 8 Oct 2019 17:04:39 +0530 Subject: [PATCH] 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")