    def test_run(self):
        """
        _input(map)[(a, b, c)]->sub_op(map)[(a, b)-(d,)]->add_op(map)[(c,)-(e,)]->_output(map)[(d, e)]
        """
        runtime_pipeline = RuntimePipeline(self.dag_dict)
        result1 = runtime_pipeline(1, 2, 3).get()
        self.assertEqual(result1[0].diff, -1)
        self.assertEqual(result1[1].sum, 13)

        result2 = runtime_pipeline(2, 2, -10).get()
        self.assertEqual(result2[0].diff, 0)
        self.assertEqual(result2[1].sum, 0)
_input(map)[(a, b, c)]->sub_op(map)[(a, b)-(d,)]->add_op(map)[(c,)-(e,)]->_output(map)[(d, e)]
tests/unittests/runtime/test_runtime_pipeline.py