def test_join_timeout(self):
    ar = MockAsyncResultSuccess(uuid(), app=self.app)
    ar2 = MockAsyncResultSuccess(uuid(), app=self.app)
    ar3 = self.app.AsyncResult(uuid())
    ts = self.app.GroupResult(uuid(), [ar, ar2, ar3])
    with self.assertRaises(TimeoutError):
        ts.join(timeout=1e-07)
    ar4 = self.app.AsyncResult(uuid())
    ar4.get = Mock()
    ts2 = self.app.GroupResult(uuid(), [ar4])
    self.assertTrue(ts2.join(timeout=0.1))
def test_join_timeout(self):
    ar = MockAsyncResultSuccess(uuid(), app=self.app)
    ar2 = MockAsyncResultSuccess(uuid(), app=self.app)
    ar3 = self.app.AsyncResult(uuid())
    ts = self.app.GroupResult(uuid(), [ar, ar2, ar3])
    with self.assertRaises(TimeoutError):
        ts.join(timeout=1e-07)
    ar4 = self.app.AsyncResult(uuid())
    ar4.get = Mock()
    ts2 = self.app.GroupResult(uuid(), [ar4])
    self.assertTrue(ts2.join(timeout=0.1))