We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a9efacc commit 4382ec4Copy full SHA for 4382ec4
src/dispatch/test/server.py
@@ -1,3 +1,4 @@
1
+import sys
2
import concurrent.futures
3
4
import grpc
@@ -47,7 +48,10 @@ def stop(self):
47
48
"""Stop the server."""
49
self._server.stop(0)
50
self._server.wait_for_termination()
- self._thread_pool.shutdown(wait=True, cancel_futures=True)
51
+ if sys.version_info >= (3, 9):
52
+ self._thread_pool.shutdown(wait=True, cancel_futures=True)
53
+ else:
54
+ self._thread_pool.shutdown(wait=True)
55
56
def __enter__(self):
57
self.start()
0 commit comments