[CI] fix some unit test since channel is passed

pypushflow/test/test_Actors.py

@@ -49,9 +49,9 @@ class TestPythonActor(unittest.TestCase):
             'name': 'Ragnar'
         }
         actor.connect(stopActor)
-        actor.trigger(inData)
+        actor.trigger((None, inData))
         stopActor.join(timeout=10)
-        out_data = stopActor.out_data
+        out_channel, out_data = stopActor.out_data
         self.assertIsNotNone(out_data)
         self.assertEqual(out_data['reply'], 'Hello Ragnar!')
 
@@ -67,11 +67,12 @@ class TestPythonActor(unittest.TestCase):
         actor.connect(stopActor)
         actor.connectOnError(errorHandler)
         errorHandler.connect(stopActor)
-        actor.trigger(inData)
+        actor.trigger((None, inData))
         stopActor.join(timeout=5)
-        out_data = stopActor.out_data
+        out_channel, out_data = stopActor.out_data
         self.assertIsNotNone(out_data)
         self.assertTrue('WorkflowException' in out_data)
+        self.assertEqual(out_channel, None)
 
     def test_ForkAndJoinActors(self):
         start = StartActor()
@@ -91,9 +92,9 @@ class TestPythonActor(unittest.TestCase):
         joinActor.connect(stop)
         # Run
         inData = {'a': 1}
-        start.trigger(inData)
+        start.trigger((None, inData))
         stop.join(timeout=5)
-        out_data = stop.out_data
+        out_channel, out_data = stop.out_data
         self.assertIsNotNone(out_data)
         logger.info(out_data)
 

pypushflow/test/test_representation.py

@@ -68,7 +68,7 @@ class TestScheme(unittest.TestCase):
 
     def testProcessing(self):
         processable_workflow = ProcessableWorkflow(scheme=self.scheme)
-        out_ = exec_(scheme=processable_workflow, input_={'data': 0,})
+        channel_out, out_ = exec_(scheme=processable_workflow, input_=(None, {'data': 0,}))
         self.assertEqual(out_['data'], 7)