justtempusername

``` cat /proc/sys/fs/inotify/max_user_watches 1048576 ``` ``` cat /proc/sys/fs/inotify/max_user_instances 128 ``` ``` cat /proc/sys/fs/inotify/max_queued_events 32768 ``` I tried increasing these values, and the spam disappears for a while, but then reappears

``` def wrapper_for_run_cpu_bound(func, *args, **kwargs): new_loop = asyncio.new_event_loop() new_loop.slow_callback_duration = 10 asyncio.set_event_loop(new_loop) try: new_loop.run_until_complete(func(*args, **kwargs)) except Exception: logger.error(traceback.format_exc()) ``` ``` pool_process = ProcessPoolExecutor(max_workers=230) asyncio.get_running_loop().run_in_executor( pool_process, wrapper_for_run_cpu_bound, func, args, ) ```...

I'm trying to figure out how to create a test case. I need this implementation because I have a lot of CPU-bound work. So why does everything work in version...

``` import asyncio import traceback from concurrent.futures import ProcessPoolExecutor import aiodns from loguru import logger pool_process = ProcessPoolExecutor(max_workers=230) def wrapper_for_run_cpu_bound(func, *args, **kwargs): new_loop = asyncio.new_event_loop() new_loop.slow_callback_duration = 10 asyncio.set_event_loop(new_loop) try:...

what about now?