pebble
pebble copied to clipboard
noxdafox
Multi threading and processing eye-candy.
Something on the line: ```python from pebble import asyncio @asyncio.process def example(*args): return args await example([1,2, 3]) ```
The initialiser method is useful for calling at process creation. Would be great if there was an equivalent finalizer method to be called just prior to closing a worker process....
Greetings! is it possible to get the pid of a process that terminates with timeoutError in ProcessPool() class?
In python multiprocessing Manager().Queue() has the function qsize() which returns the number of processes completed or running. Is there a way of logging how far through all the processes I...
I am using ProcessPool with 12 workers and 50 tasks; the pool is being used over and over to perform long tasks with timeout. I want to be able to...
The full traceback is ``` RuntimeError: dictionary changed size during iteration File "threading.py", line 910, in run self._target(*self._args, **self._kwargs) File "pebble/pool/process.py", line 167, in pool_manager_loop pool_manager.update_status() File "pebble/pool/process.py", line 220,...
I have the following code: ``` async def syncTrackers(): # trackerCollections = await magiceden.magiceden.allCollections() with ProcessPoolExecutor(max_workers=4) as executor: trackerCollections = await botutilities.collections.getTrackerCollection(con, None) syncFutures = [executor.submit(await nftAnalytics.dataSync.syncCollectionStats(collection['symbol'])) for collection in...
Python 2 EOL was in 2020. Its deprecation would allow to support new features such as #90 as well as remove a fair bit of code.
I have a need to wait for the concurrent process to finish, and there's currently no way to `.join()` the open process. Added a reference from the returned future to...
## User story As a developer I would like to run a generator in another process, and get the results one by one to be able to process them in...
