@@ -108,15 +108,15 @@ def test_als_worker_ids():
108108 W_ps = W .copy ()
109109 W_ps ["persis_state" ] = np .array ([EVAL_GEN_TAG , 0 , 0 , 0 ])
110110 als = AllocSupport (W_ps , True )
111- assert als .avail_worker_ids (persistent = True ) == [
111+ assert als .avail_worker_ids (persistent = EVAL_GEN_TAG ) == [
112112 1
113113 ], "avail_worker_ids() didn't return expected persistent worker list."
114114
115115 W_ar = W .copy ()
116116 W_ar ["active_recv" ] = np .array ([True , 0 , 0 , 0 ])
117117 W_ar ["persis_state" ] = np .array ([EVAL_GEN_TAG , 0 , 0 , 0 ])
118118 als = AllocSupport (W_ar , True )
119- assert als .avail_worker_ids (persistent = True , active_recv = True ) == [
119+ assert als .avail_worker_ids (persistent = EVAL_GEN_TAG , active_recv = True ) == [
120120 1
121121 ], "avail_worker_ids() didn't return expected persistent worker list."
122122
@@ -138,7 +138,6 @@ def test_als_worker_ids():
138138def test_als_evaluate_gens ():
139139 W_gens = W .copy ()
140140 W_gens ["active" ] = np .array ([EVAL_GEN_TAG , 0 , EVAL_GEN_TAG , 0 ])
141- W_gens ["worker_type" ] = np .array ([EVAL_GEN_TAG , 0 , EVAL_GEN_TAG , 0 ])
142141 als = AllocSupport (W_gens , True )
143142 assert als .count_gens () == 2 , "count_gens() didn't return correct number of active generators"
144143
0 commit comments