Add missing coroutine decorator on pg queue _subscribe function.