diff --git a/rowers/utils.py b/rowers/utils.py index fdef303a..ce2a017f 100644 --- a/rowers/utils.py +++ b/rowers/utils.py @@ -273,6 +273,7 @@ def isbreakthrough(delta,cpvalues,p0,p1,p2,p3,ratio): cpvalues = cpvalues.values.astype(int) pwr = pwr.astype(int) + res = np.sum(cpvalues>pwr) res2 = np.sum(cpvalues>pwr2) @@ -289,7 +290,7 @@ def isbreakthrough(delta,cpvalues,p0,p1,p2,p3,ratio): btdf.sort_values('delta',axis=0,inplace=True) - return res>1,btdf,res2>1 + return res>=1,btdf,res2>=1 def myqueue(queue,function,*args,**kwargs):