project-codeflare / rayvens

Rayvens makes it possible for data scientists to access hundreds of data services within Ray with little effort.
Apache License 2.0
43 stars 7 forks source link

Make queue threads smarter #48

Open doru1004 opened 2 years ago

doru1004 commented 2 years ago

We would like to have queue threads time out if no message was received for a period of time. This will result in the thread sending an Empty message to signal this. The empty message will be caught on the consumer side but not processed further.