Add failing test for concurrent scatter operations
@@ -5436,6 +5436,15 @@ def test_tuple_keys(c, s, a, b):
assert (yield future) == 3
+@gen_cluster(client=True)
+def test_multiple_scatter(c, s, a, b):
+ for i in range(5):
+ x = c.scatter(1, direct=True)
+
+ x = yield x
+ x = yield x
+
+
@gen_cluster(client=True)
def test_map_large_kwargs_in_graph(c, s, a, b):
np = pytest.importorskip("numpy")
