Pass instance method to map/starmap

[prathik-quartic]

Description

Can we provide a instance method instead of a static function?

async with Pool() as pool:
    await pool.map(self.write_data, node)

I get back this error. Not sure what to make of this error.

Traceback (most recent call last):
  File "/usr/lib/python3.8/multiprocessing/queues.py", line 239, in _feed
    obj = _ForkingPickler.dumps(obj)
  File "/usr/lib/python3.8/multiprocessing/reduction.py", line 51, in dumps
    cls(buf, protocol).dump(obj)
TypeError: cannot pickle '_thread.lock' object

Can someone please help me out?

Details

• OS: Ubuntu-20
• Python version: 3.8
• aiomultiprocess version: 0.9.0
• Can you repro on master?
• Can you repro in a clean virtualenv?