I try to run pileline using mutliprocessing with hyperscan.
i use with closing(Pool(args.nr_proc)) as pool: to define process_pool
I use pool.apply_async() to generate list of testks
When I run tasks I get:
raise self._value
File "/usr/lib/python3.9/multiprocessing/pool.py", line 537, in _handle_tasks
put(task)
File "/usr/lib/python3.9/multiprocessing/connection.py", line 211, in send
self._send_bytes(_ForkingPickler.dumps(obj))
File "/usr/lib/python3.9/multiprocessing/reduction.py", line 51, in dumps
cls(buf, protocol).dump(obj)
TypeError: cannot pickle 'hyperscan.Database' object```
I try to run pileline using mutliprocessing with hyperscan.
i use
with closing(Pool(args.nr_proc)) as pool:
to define process_pool I usepool.apply_async()
to generate list of testksWhen I run tasks I get: