def test_join_native_raises(self):
    ts = self.app.GroupResult(uuid(), [self.app.AsyncResult(uuid())])
    ts.iter_native = Mock()
    ts.iter_native.return_value = iter([(uuid(), {'status': states.FAILURE, 'result': KeyError()})])
    with self.assertRaises(KeyError):
        ts.join_native(propagate=True)
def test_join_native_raises(self):
    ts = self.app.GroupResult(uuid(), [self.app.AsyncResult(uuid())])
    ts.iter_native = Mock()
    ts.iter_native.return_value = iter([(uuid(), {'status': states.FAILURE, 'result': KeyError()})])
    with self.assertRaises(KeyError):
        ts.join_native(propagate=True)