File tree Expand file tree Collapse file tree 2 files changed +10
-1
lines changed
Expand file tree Collapse file tree 2 files changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -730,7 +730,7 @@ def __repr__(self) -> str:
730730 return self .__str__ ()
731731
732732
733- def main ():
733+ def main (): # pragma: no cover
734734 import argparse
735735 import random
736736
Original file line number Diff line number Diff line change @@ -64,6 +64,11 @@ def test_set_dependency_error(self):
6464 def test_sink_worker (self ):
6565 worker = DummyWorker ()
6666 self .graph .add_worker (worker )
67+
68+ # Cannot set a sink that is not being produced
69+ with self .assertRaises (ValueError ):
70+ self .graph .set_sink (worker , Task )
71+
6772 self .graph .set_sink (worker , DummyTask )
6873 self .assertIsNotNone (self .graph ._sink_worker )
6974
@@ -131,6 +136,10 @@ def consume_work(self, task: DummyTask):
131136 self .graph .prepare (display_terminal = False )
132137 self .graph .set_entry (worker )
133138
139+ # Try to add work for a non-entry worker
140+ with self .assertRaises (ValueError ):
141+ self .graph .add_work (test_worker , initial_task )
142+
134143 # Add metadata to be tracked with the task
135144 metadata = {"test_key" : "test_value" }
136145 provenance = self .graph .add_work (worker , initial_task , metadata = metadata )
You can’t perform that action at this time.
0 commit comments