We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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
When calling the ASYNC script and the defined time to collect data is over, the process is not ended and remains in execution.
This like seems to be the one that is supposed to cancel the subscription consumption and end the thread, but it's not enough to end the thread:
dj-dna-streams-python/dnaStreaming/demo/show_stream_async.py
Line 34 in 93253d4
As per the Google Cloud Pub/Sub documentation, the cancel() function is not enough to end the thread and there's a suggestion to use result() right after that. https://googleapis.dev/python/pubsub/latest/subscriber/api/futures.html#google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel
cancel()
result()
Please ensure the whole process ends in a clean way when the condition is met.
The text was updated successfully, but these errors were encountered:
No branches or pull requests
When calling the ASYNC script and the defined time to collect data is over, the process is not ended and remains in execution.
This like seems to be the one that is supposed to cancel the subscription consumption and end the thread, but it's not enough to end the thread:
dj-dna-streams-python/dnaStreaming/demo/show_stream_async.py
Line 34 in 93253d4
As per the Google Cloud Pub/Sub documentation, the
cancel()
function is not enough to end the thread and there's a suggestion to useresult()
right after that.https://googleapis.dev/python/pubsub/latest/subscriber/api/futures.html#google.cloud.pubsub_v1.subscriber.futures.StreamingPullFuture.cancel
Please ensure the whole process ends in a clean way when the condition is met.
The text was updated successfully, but these errors were encountered: