You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
This error appears when a FilterTagged sends a TaggedValue to a Serializer instance.
On the latest version, the attribute Oper.tag was removed, thereafter the last parameter tag was removed for the method Node.create_opers(), but it keeps being called on Source.run():
anderson@Inspiron-5423:~/Sucuri/examples/mine$ python pipeline.py 1
Roots [<pyDF.nodes.Source instance at 0x7fcaa0dd6d40>]
Starting Worker-1
Main loop
I am worker 0
Process Worker-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/home/anderson/projeto_final/pyDF/pydf.py", line 33, in run
node.run(task.args, self.wid, self.operq)
File "/home/anderson/projeto_final/pyDF/nodes.py", line 45, in run
opers = self.create_oper(TaggedValue(result, tag), workerid, operq, tag)
TypeError: create_oper() takes exactly 4 arguments (5 given)
Just removing the parameter from the call in Source.run() does not work either, because Serializer uses the tag attribute, which no longer exists:
anderson@Inspiron-5423:~/Sucuri/examples/mine$ python pipeline.py 1
Roots [<pyDF.nodes.Source instance at 0x7f3b3f62e0e0>]
Starting Worker-1
Main loop
I am worker 0
Process Worker-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/home/anderson/Sucuri/pyDF/pydf.py", line 36, in run
node.run(task.args, self.wid, self.operq)
File "/home/anderson/Sucuri/pyDF/nodes.py", line 121, in run
if args[0].tag == self.next_tag:
AttributeError: Oper instance has no attribute 'tag'
The text was updated successfully, but these errors were encountered:
System information (version):
This error appears when a FilterTagged sends a TaggedValue to a Serializer instance.
On the latest version, the attribute Oper.tag was removed, thereafter the last parameter tag was removed for the method Node.create_opers(), but it keeps being called on Source.run():
anderson@Inspiron-5423:~/Sucuri/examples/mine$ python pipeline.py 1
Roots [<pyDF.nodes.Source instance at 0x7fcaa0dd6d40>]
Starting Worker-1
Main loop
I am worker 0
Process Worker-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/home/anderson/projeto_final/pyDF/pydf.py", line 33, in run
node.run(task.args, self.wid, self.operq)
File "/home/anderson/projeto_final/pyDF/nodes.py", line 45, in run
opers = self.create_oper(TaggedValue(result, tag), workerid, operq, tag)
TypeError: create_oper() takes exactly 4 arguments (5 given)
Just removing the parameter from the call in Source.run() does not work either, because Serializer uses the tag attribute, which no longer exists:
anderson@Inspiron-5423:~/Sucuri/examples/mine$ python pipeline.py 1
Roots [<pyDF.nodes.Source instance at 0x7f3b3f62e0e0>]
Starting Worker-1
Main loop
I am worker 0
Process Worker-1:
Traceback (most recent call last):
File "/usr/lib/python2.7/multiprocessing/process.py", line 258, in _bootstrap
self.run()
File "/home/anderson/Sucuri/pyDF/pydf.py", line 36, in run
node.run(task.args, self.wid, self.operq)
File "/home/anderson/Sucuri/pyDF/nodes.py", line 121, in run
if args[0].tag == self.next_tag:
AttributeError: Oper instance has no attribute 'tag'
The text was updated successfully, but these errors were encountered: