|
|
|
@@ -60,7 +60,14 @@ impl Drop for EventStreamThreadHandle { |
|
|
|
if self.handle.is_empty() { |
|
|
|
tracing::trace!("waiting for event stream thread"); |
|
|
|
} |
|
|
|
match self.handle.recv_timeout(Duration::from_secs(20)) { |
|
|
|
|
|
|
|
// TODO: The event stream duration has been shorten due to |
|
|
|
// Python Reference Counting not working properly and deleting the node |
|
|
|
// before deleting event creating a race condition. |
|
|
|
// |
|
|
|
// In the future, we hope to fix this issue so that |
|
|
|
// the event stream can be properly waited for every time. |
|
|
|
match self.handle.recv_timeout(Duration::from_secs(1)) { |
|
|
|
Ok(Ok(())) => { |
|
|
|
tracing::trace!("event stream thread finished"); |
|
|
|
} |
|
|
|
|