Method target

pymongo/asynchronous/topology.py:194–195

()

            weak: weakref.ReferenceType[queue.Queue[Any]]

            async def target() -> bool:
                return process_events_queue(weak)

            executor = periodic_executor.AsyncPeriodicExecutor(
                interval=common.EVENTS_QUEUE_FREQUENCY,