When using multiple device code, the library gives me operation already running error

[KaustubhPawar0629]

I wrote most of the code for the code below and the code is really similar to the code that I used for a one device connection, and that worked, but when I try to run this on the raspberry pi, it says that there is already a operation running for the raspberry pi. I also checked the raspberry pi's bluetooth to find that there is nothing connected to the bluetooth so there are no operations currently reading. Is there a error in my code or is it a problem with threads creation on the pi?
My code:

import asyncio
from bleak import *
import bitstruct
import struct
from functools import partial


HEART_RATE_SERVICE_UUID = "00002A37-0000-1000-8000-00805f9b34fb"

devices = [
    {"address": "C6:4B:DF:A5:36:0B", "name": "sensor 1"},
    {"address": "A0:9E:1A:49:A8:51", "name": "sensor 2"},
]


async def connect_and_read(address, name):
    async with BleakClient(address) as client:
        try:
            print(f"Connecting to {name}: {client.is_connected}")

            async def hr_val_handler(sender, data, device_address):
                hr_val = struct.unpack_from(
                    "<H" if bitstruct.unpack("b1", data)[0] else "<B", data, 1
                )[0]
                print(f"HR Value: {hr_val}, from: {device_address}")

            partial_handler = partial(hr_val_handler, device_address=name)
            await client.start_notify(HEART_RATE_SERVICE_UUID, partial_handler)

            while client.is_connected:
                await asyncio.sleep(1)

        except Exception as e:
            print(f"Error connecting to {name}: {e}")


async def main():
    tasks = [connect_and_read(d["address"], d["name"]) for d in devices]
    await asyncio.gather(*tasks)

    try:
        input("Press Enter to stop")
    except Exception as e:
        print(f"Error: {e}")
        return

if __name__ == "__main__":
    asyncio.run(main())

My error:

Traceback (most recent call last):
  File "multiple.py", line 48, in <module>
    asyncio.run(main())
  File "/usr/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 584, in run_until_complete
    return future.result()
  File "multiple.py", line 39, in main
    await asyncio.gather(*tasks)
  File "multiple.py", line 17, in connect_and_read
    async with BleakClient(address) as client:
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 491, in __aenter__
    await self.connect()
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 531, in connect
    return await self._backend.connect(**kwargs)
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/client.py", line 128, in connect
    backend=BleakScannerBlueZDBus,
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 313, in find_device_by_address
    **kwargs,
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 369, in find_device_by_filter
    async with cls(detection_callback=apply_filter, **kwargs):
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 152, in __aenter__
    await self._backend.start()
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/scanner.py", line 195, in start
    self._handle_device_removed,
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/manager.py", line 368, in active_scan
    assert_reply(reply)
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/utils.py", line 22, in assert_reply
    raise BleakDBusError(reply.error_name, reply.body)
bleak.exc.BleakDBusError: [org.bluez.Error.InProgress] Operation already in progress
pi@heartbeat-horse-race:~/Documents/kaustubhtrial $ python3 multiple.py 
Traceback (most recent call last):
  File "multiple.py", line 48, in <module>
    asyncio.run(main())
  File "/usr/lib/python3.7/asyncio/runners.py", line 43, in run
    return loop.run_until_complete(main)
  File "/usr/lib/python3.7/asyncio/base_events.py", line 584, in run_until_complete
    return future.result()
  File "multiple.py", line 39, in main
    await asyncio.gather(*tasks)
  File "multiple.py", line 17, in connect_and_read
    async with BleakClient(address) as client:
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 491, in __aenter__
    await self.connect()
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 531, in connect
    return await self._backend.connect(**kwargs)
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/client.py", line 128, in connect
    backend=BleakScannerBlueZDBus,
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 313, in find_device_by_address
    **kwargs,
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 369, in find_device_by_filter
    async with cls(detection_callback=apply_filter, **kwargs):
  File "/usr/local/lib/python3.7/dist-packages/bleak/__init__.py", line 152, in __aenter__
    await self._backend.start()
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/scanner.py", line 195, in start
    self._handle_device_removed,
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/manager.py", line 368, in active_scan
    assert_reply(reply)
  File "/usr/local/lib/python3.7/dist-packages/bleak/backends/bluezdbus/utils.py", line 22, in assert_reply
    raise BleakDBusError(reply.error_name, reply.body)
bleak.exc.BleakDBusError: [org.bluez.Error.InProgress] Operation already in progress

[dlech]

This needs an asyncio.Lock() to prevent both devices from trying to connect at the same time.