-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Drain result queue on stop #11
Labels
question
Further information is requested
Comments
For normal stops, this actually prevents data loss. The workflow is
If stop is called because of an exception in the main task, |
We need a timeout for |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
The stop method is waiting with
result_queue.join()
. So we need to empty all results from queue before stopThe text was updated successfully, but these errors were encountered: