Added bypass for dask distributed timeout

Author: seanlaw

tests/test_aamp_ostinato.py

@@ -21,7 +21,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 @pytest.mark.parametrize(

tests/test_aamp_stimp.py

@@ -27,7 +27,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 @pytest.mark.parametrize("T", T)

tests/test_aampdist.py

@@ -20,7 +20,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_aamped.py

@@ -22,7 +22,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_maamped.py

@@ -22,7 +22,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_mpdist.py

@@ -22,7 +22,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_mstumped.py

@@ -24,7 +24,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_non_normalized_decorator.py

@@ -75,7 +75,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 test_data = [

tests/test_ostinato.py

@@ -23,7 +23,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 @pytest.mark.parametrize(

tests/test_stimp.py

@@ -27,7 +27,7 @@ def dask_cluster():
     try:
         cluster.close(timeout=60)
     except tornado.ioloop.TimeoutError:  # pragma: no cover
-        cluster.shutdown()
+        pass
 
 
 @pytest.mark.parametrize("T", T)