Fix TestOutputStream test

siddhi-io · Oct 8, 2019 · 951d0db · 951d0db
1 parent 8ecddb9
commit 951d0db
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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")