diff --git a/core/base/libs/podop/podop/postfix.py b/core/base/libs/podop/podop/postfix.py index 84c7b08d..3140a3a8 100644 --- a/core/base/libs/podop/podop/postfix.py +++ b/core/base/libs/podop/podop/postfix.py @@ -4,7 +4,6 @@ import asyncio import logging - class NetstringProtocol(asyncio.Protocol): """ Netstring asyncio protocol implementation. @@ -91,7 +90,7 @@ class SocketmapProtocol(NetstringProtocol): if space != -1: name = string[:space].decode('ascii') key = string[space+1:].decode('utf8') - return asyncio.async(self.process_request(name, key)) + return asyncio.ensure_future(self.process_request(name, key)) async def process_request(self, name, key): """ Process a request by querying the provided map.