search

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

Add waiting for disconnects #17

Closed doru1004 closed 3 years ago

doru1004 commented 3 years ago

Add two types of waiting before disconnecting a source/sink:

  1. waiting for a stream to be idle for a fixed period of time before disconnecting (to be used with non-periodic sources/sinks).
  2. waiting for a fixed amount of time before disconnecting (to be used for periodic sources/sinks).