updated tests, todo: new tests

Author: mathisxy

tests/test_graph.py

@@ -3,7 +3,7 @@
 from asyncio import Lock
 from collections.abc import Hashable
 
-from edgygraph import Graph, Node, State, Shared, START, END, Config
+from edgygraph import Graph, Node, State, Shared, START, END
 from edgygraph.diff import ChangeTypes, Diff, Change, ChangeConflictException
 
 
@@ -183,7 +183,7 @@ def test_chain_of_two_nodes(self):
         n2 = IncrementNode()
         state = SimpleState(value=0)
         shared = SimpleShared()
-        g = Graph(edges=[(START, n1, (n1, n2), (n2, None), END)])
+        g = Graph(edges=[(START, n1, n2, END)])
         result_state, _ = asyncio.run(g(state, shared))
         assert result_state.value == 2
 
@@ -322,7 +322,8 @@ def test_error_edge_by_exception_type(self):
         shared = SimpleShared()
         g = Graph(edges=[(
             START, raiser,
-            (ValueError, recovery),
+            ValueError, 
+            recovery,
             END)
         ])
         result_state, _ = asyncio.run(g(state, shared))
@@ -336,7 +337,8 @@ def test_error_edge_by_node_and_exception_type(self):
         shared = SimpleShared()
         g = Graph(edges=[(
             START, raiser,
-            ((raiser, RuntimeError), recovery),
+            (raiser, RuntimeError),
+            recovery,
             END)
         ])
         result_state, _ = asyncio.run(g(state, shared))
@@ -362,7 +364,8 @@ def test_wrong_exception_type_not_caught(self):
         shared = SimpleShared()
         g = Graph(edges=[(
             START, raiser,
-            (ValueError, RecoveryNode()),
+            ValueError, 
+            RecoveryNode(),
             END)
         ])
         with pytest.raises(ExceptionGroup):
@@ -382,8 +385,8 @@ def test_instant_node_runs_in_same_step(self):
         state = SimpleState(value=0)
         shared = SimpleShared()
         g = Graph(edges=[(
-            START, inc,
-            (inc, noop, Config(instant=True)),
+            START, 
+            [inc, noop],
             END)
         ])
         result_state, _ = asyncio.run(g(state, shared))
@@ -405,9 +408,11 @@ def test_list_source_registers_for_each_node(self):
         shared = SimpleShared()
 
         g = Graph(edges=[(
-            START, [n1, n3],
-            (n3, n2),
-            ([n1, n2], join),
+            START, 
+            [n1, -n3],
+            n2,
+            [+n3, +n2], 
+            join,
             END)
         ])
         result_state, _ = asyncio.run(g(state, shared))