message: Disable tests that fail on Windows with Python 3.8.
  The tests in client_test.py that fail with Windows and Python 3.8 have been
  temporarily disabled until the issue has been fixed. Tests that call
  self.assertRaises have been failing.
  is probably related.
diff: @@ -19,6 +19,8 @@ from __future__ import division
  from __future__ import print_function
  import collections
  +import platform
  +import sys
  import threading
  import time
  from absl import logging
  @@ -137,6 +139,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  coord.join([t])
  def testWaitRaiseErrorAfterMarkFailure(self):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue = client._CoordinatedClosureQueue()
  closure_queue.put(self._create_closure(closure_queue._cancellation_mgr))
  closure = closure_queue.get()
  @@ -183,6 +189,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  return closure_queue, closure1, closure2
  def testPutRaiseError(self):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue, _, closure2 = self._put_two_closures_and_get_one()
  closure_queue.mark_failed(ValueError())
  @@ -202,6 +212,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  closure_queue.put(self._create_closure(closure_queue._cancellation_mgr))
  def testWaitRaiseError(self):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue, _, closure2 = self._put_two_closures_and_get_one()
  closure_queue.mark_failed(ValueError())
  @@ -220,6 +234,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  closure_queue.wait()
  def testDoneRaiseError(self):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue, _, _ = self._put_two_closures_and_get_one()
  self.assertFalse(closure_queue.done())
  @@ -236,6 +254,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  closure_queue.mark_failed(e)
  def _test_cancel_closure_when_error(self, call_wait):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue, closure1, closure2 = self._put_two_closures_and_get_one()
  closure_queue.put(self._create_closure(closure_queue._cancellation_mgr))
  closure_queue.get()
  @@ -306,6 +328,10 @@ class CoordinatedClosureQueueTest(test.TestCase):
  self._test_cancel_closure_when_error(call_wait=False)
  def testStateIsRestoredAfterJoinIsCalled(self):
  + if sys.version_info >= (3, 8) and platform.system() == 'Windows':
  + # TODO(b/165013260): Fix this
  + self.skipTest('Test is currently broken on Windows with Python 3.8')
  +
  closure_queue, _, _ = self._put_two_closures_and_get_one()
  self.assertEqual(closure_queue._inflight_closure_count, 1)
  closure_queue.mark_failed(ValueError('test error'))
  