Cast the complete queue to sub class to avoid AttributeError

5 years ago · 2c24272bbd
parent 5b087c9d8b
commit 2c24272bbd
1 changed files with 1 additions and 1 deletions
--- a/src/python/grpcio/grpc/_cython/_cygrpc/aio/grpc_aio.pyx.pxi
+++ b/src/python/grpcio/grpc/_cython/_cygrpc/aio/grpc_aio.pyx.pxi
@ -105,7 +105,7 @@ cdef _actual_aio_shutdown():
        )
        future.add_done_callback(_grpc_shutdown_wrapper)
    elif _global_aio_state.engine is AsyncIOEngine.POLLER:
-        _global_aio_state.cq.shutdown()
+        (<PollerCompletionQueue>_global_aio_state.cq).shutdown()
        grpc_shutdown_blocking()
    else:
        raise ValueError('Unsupported engine type [%s]' % _global_aio_state.engine)