Author DAVID ALEJANDRO Pineda
Recipients DAVID ALEJANDRO Pineda, gvanrossum, yselivanov
Date 2017-02-09.21:41:24
SpamBayes Score -1.0
Marked as misclassified Yes
Message-id <1486676485.08.0.362566272702.issue29517@psf.upfronthosting.co.za>
In-reply-to
Content
Hello.

I'm working in a real time data collector project. I'm using asyncio and multiprocessing (run_in_executor).
In python 3.5 worked fine but in python 3.6 not, gave to me this error:
 "Traceback (most recent call last):
  File "/usr/local/lib/python3.6/multiprocessing/queues.py", line 241, in _feed
    obj = _ForkingPickler.dumps(obj)
  File "/usr/local/lib/python3.6/multiprocessing/reduction.py", line 51, in dumps
    cls(buf, protocol).dump(obj)
AttributeError: Can't pickle local object 'WeakSet.__init__.<locals>._remove'
"

I tracked and the problem is when i run some method in run_in_executor with the functools.partial.

Before this version the system works fine.

The main file is local.py (to run with local administration using a socket)
And the engine is in engine.py

The project (in development):
https://gitlab.com/pineiden/collector
History
Date User Action Args
2017-02-09 21:41:25DAVID ALEJANDRO Pinedasetrecipients: + DAVID ALEJANDRO Pineda, gvanrossum, yselivanov
2017-02-09 21:41:25DAVID ALEJANDRO Pinedasetmessageid: <1486676485.08.0.362566272702.issue29517@psf.upfronthosting.co.za>
2017-02-09 21:41:24DAVID ALEJANDRO Pinedalinkissue29517 messages
2017-02-09 21:41:24DAVID ALEJANDRO Pinedacreate