Removing tests for Mux/Demux actors.
@@ -4706,75 +4706,6 @@ class TestPortmappingScript(CalvinTestBase):
actual = self._run_test(script, len(expected))
self.assert_lists_equal(expected, actual)
- def testMapMux(self):
- script = r"""
- snk : test.Sink(store_tokens=1, quiet=1)
- input: std.Counter()
- mux: flow.Mux(mapping={"one": &out1.out, "two":&out2.out, "three":&out3.out})
- sel: json.Items()
- out1 : text.PrefixString(prefix="tag-1:")
- out2 : text.PrefixString(prefix="tag-2:")
- out3 : text.PrefixString(prefix="tag-3:")
- input.integer > out1.in
- input.integer > out2.in
- input.integer > out3.in
- out1.out > mux.token
- out2.out > mux.token
- out3.out > mux.token
- ["one", "two", "three"] > sel.list
- sel.item > mux.select
- mux.token > snk.token
- """
- expected = [
- "tag-1:1",
- "tag-2:2",
- "tag-3:3",
- "tag-1:4",
- "tag-2:5",
- "tag-3:6",
- "tag-1:7",
- "tag-2:8",
- "tag-3:9",
- ]
- actual = self._run_test(script, len(expected))
- self.assert_lists_equal(expected, actual)
-
- @pytest.mark.xfail
- def testMapDemux(self):
- script = r"""
- snk : test.Sink(store_tokens=1, quiet=1)
- input: std.Counter()
- dem: flow.Demux(select={"one":&out1.in, "two": &out2.in, "three": &out3.in})
- sel: json.Items()
- out1 : text.PrefixString(prefix="tag-1:")
- out2 : text.PrefixString(prefix="tag-2:")
- out3 : text.PrefixString(prefix="tag-3:")
- coll : flow.Mux(mapping={"one":&out1.out, "two": &out2.out, "three": &out3.out})
- input.integer > dem.token
- dem.token > out1.in
- dem.token > out2.in
- dem.token > out3.in
- ["one", "two", "three"] > sel.list
- sel.item > dem.select, coll.select
- dem.default > voidport
- out1.out > coll.token
- out2.out > coll.token
- out3.out > coll.token
- coll.token > snk.token
- """
- expected = [
- "tag-1:1",
- "tag-2:2",
- "tag-3:3",
- "tag-1:4",
- "tag-2:5",
- "tag-3:6",
- "tag-1:7",
- "tag-2:8",
- "tag-3:9",
- ]
- actual = self._run_test(script, len(expected))
- self.assert_lists_equal(expected, actual)
def testMapDispatchCollect(self):
script = r"""
