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
Hi, I've encountered a possible bug while trying to filter out data passed along the pipeline.
I've built a short demo to demonstrate what I'm experiencing in a more complex scenario.
Filtering works out fine. The issue arise when I try to gracefully terminate the pipeline execution with a single Ctrl + C.
When the extractor yields 10 and data is not filtered a single Ctrl + C terminates the execution. When instead data is 0 and is filtered out by filter_data, the pipeline halts the execution but the bonobo.run method hangs and does not return. I need to force quit with a repeated SIGKILL.
Am I filtering data in the way bonobo expects me to do it? I'm quite new to the library and I haven't found any tip regarding filtering/removing data from the pipeline. Is having a processor return None the correct way to deal with filtering operations?
I'm running python 3.7.9 with bonobo 0.6.4.
Any help is appreciated, thanks!
The text was updated successfully, but these errors were encountered:
BalzySte
changed the title
Gracefully termination hangs when filtering data
Graceful termination hangs when filtering data
Feb 4, 2021
Hi, I've encountered a possible bug while trying to filter out data passed along the pipeline.
I've built a short demo to demonstrate what I'm experiencing in a more complex scenario.
Filtering works out fine. The issue arise when I try to gracefully terminate the pipeline execution with a single
Ctrl + C
.When the extractor yields
10
and data is not filtered a singleCtrl + C
terminates the execution. When instead data is0
and is filtered out byfilter_data
, the pipeline halts the execution but thebonobo.run
method hangs and does not return. I need to force quit with a repeatedSIGKILL
.Am I filtering data in the way bonobo expects me to do it? I'm quite new to the library and I haven't found any tip regarding filtering/removing data from the pipeline. Is having a processor return
None
the correct way to deal with filtering operations?I'm running
python 3.7.9
withbonobo 0.6.4
.Any help is appreciated, thanks!
The text was updated successfully, but these errors were encountered: