-
Notifications
You must be signed in to change notification settings - Fork 84
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
Option for blocking publish #49
Comments
Clarification of python methods: in django_grip the |
Perhaps a good model would be to send arbitrary |
Interesting. There's an However, I just realized this may not be needed because you can manually invoke the same waiting effect as the atexit handler like this: from django_grip import get_pubcontrol
send_event(...)
get_pubcontrol().wait_all_sent() Let me know if that works. |
Thanks for the reply. Yes, that looks like it should do what I want. I will try it out. |
Feature request: Support for the "blocking" option from django_grip in eventstream.
Rationale:
We are running into an issue where some messages are not sent from celery workers. I suspect what is happening is that the celery worker process is exiting (including daemon threads) before the event is published by the daemon thread in pubcontrol.
We have logging in place just before calling
eventstream.send_event
, and the call is being made by the celery workers, but the message is not received by the client. This is a intermittent problem. We observed this with a self-hosted pushpin proxy, and continue to see this using fanout.io.The text was updated successfully, but these errors were encountered: