File tree Expand file tree Collapse file tree 1 file changed +0
-45
lines changed Expand file tree Collapse file tree 1 file changed +0
-45
lines changed Original file line number Diff line number Diff line change @@ -610,51 +610,6 @@ def Workflow(in_dir: Directory):
610610 wf (cache_dir = cache_dir )
611611
612612
613- def test_hash_changes_in_workflow_graph (tmpdir ):
614- class X :
615- """Dummy class with unstable hash (i.e. which isn't altered in a node in which
616- it is an input)"""
617-
618- value = 1
619-
620- def __bytes_repr__ (self , cache ):
621- """Bytes representation from class attribute, which will be changed be
622- 'alter_x" node.
623-
624- NB: this is a contrived example where the bytes_repr implementation returns
625- a bytes representation of a class attribute in order to trigger the exception,
626- hopefully cases like this will be very rare"""
627- yield bytes (self .value )
628-
629- @python .define (outputs = ["x" , "y" ])
630- def Identity (x : X ) -> ty .Tuple [X , int ]:
631- return x , 99
632-
633- @python .define
634- def AlterX (y ):
635- X .value = 2
636- return y
637-
638- @python .define
639- def ToTuple (x , y ):
640- return (x , y )
641-
642- @workflow .define
643- def Workflow (x ):
644- taska = workflow .add (Identity (x = x ))
645- taskb = workflow .add (AlterX (y = taska .y ))
646- taskc = workflow .add (ToTuple (x = taska .x , y = taskb .out ))
647- return taskc .out
648-
649- wf = Workflow (x = X ())
650-
651- with pytest .raises (
652- RuntimeError , match = "Graph of 'wf_with_blocked_tasks' workflow is not empty"
653- ):
654- with Submitter (worker = "cf" , cache_dir = tmpdir ) as sub :
655- sub (wf )
656-
657-
658613@python .define
659614def to_tuple (x , y ):
660615 return (x , y )
You can’t perform that action at this time.
0 commit comments