Skip to content

Commit 3f6d951

Browse files
author
fbeitler
committed
Fix missing imports
Add missing closing braket
1 parent a6c5bf4 commit 3f6d951

File tree

3 files changed

+9
-2
lines changed

3 files changed

+9
-2
lines changed

pymodbus/client/asynchronous/async_io/__init__.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -617,10 +617,10 @@ def protocol_lost_connection(self, protocol):
617617
self.connected = False
618618
self.protocol = None
619619
if self.host:
620-
asyncio.ensure_future(self._reconnect(), loop=self.loop)
620+
asyncio.create_task(self._reconnect())
621621
else:
622622
_logger.error('Factory protocol disconnect '
623-
'callback called while not connected.'
623+
'callback called while not connected.')
624624

625625
async def _reconnect(self):
626626
_logger.debug('Waiting %d ms before next '

test/test_client_async_asyncio.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,4 @@
1+
from pymodbus.client.asynchronous import schedulers
12
from pymodbus.compat import PYTHON_VERSION
23
import pytest
34
from unittest import mock
@@ -11,6 +12,11 @@
1112
from pymodbus.transaction import ModbusSocketFramer
1213
from pymodbus.bit_read_message import ReadCoilsRequest, ReadCoilsResponse
1314
protocols = [BaseModbusAsyncClientProtocol, ModbusUdpClientProtocol, ModbusClientProtocol]
15+
from pymodbus.client.asynchronous.tcp import AsyncModbusTCPClient
16+
from pymodbus.client.asynchronous.udp import AsyncModbusUDPClient
17+
from pymodbus.client.asynchronous.tls import AsyncModbusTLSClient
18+
from pymodbus.client.asynchronous.serial import AsyncModbusSerialClient
19+
1420

1521

1622
class TestAsyncioClient(object):

test/test_server_asyncio.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
# Fixture
2323
# ---------------------------------------------------------------------------#
2424
import platform
25+
import ssl
2526
from pkg_resources import parse_version
2627
_logger = logging.getLogger()
2728

0 commit comments

Comments
 (0)