fix scatter tests

ICRAR · Jan 14, 2022 · 0c1170f · 0c1170f
1 parent 0595a7b
commit 0c1170f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/daliuge-engine/test/apps/test_simple.py b/daliuge-engine/test/apps/test_simple.py
@@ -146,7 +146,7 @@ def test_helloworldapp(self):
 
     def test_parallelHelloWorld(self):
         m0 = InMemoryDROP("m0", "m0")
-        s = GenericScatterApp("s", "s")
+        s = GenericScatterApp("s", "s", num_of_copies=4)
         greets = ["World", "Solar system", "Galaxy", "Universe"]
         m0.write(pickle.dumps(greets))
         s.addInput(m0)
@@ -194,7 +194,7 @@ def test_genericScatter(self):
         data_in = random.randint(0, 100, size=100)
         b = InMemoryDROP("b", "b")
         b.write(pickle.dumps(data_in))
-        s = GenericScatterApp("s", "s")
+        s = GenericScatterApp("s", "s", num_of_copies=2)
         s.addInput(b)
         o1 = InMemoryDROP("o1", "o1")
         o2 = InMemoryDROP("o2", "o2")