Nodes with no inputs has empty events stream #500
Description
If a node does not specify any inputs, it will have no event stream. And the event stream is always returning None.
This is however misleading as we might want to check the event stream for other event than INPUT event such as Stopping event.
Quick example
use std::time::Duration;
use dora_node_api::{self, dora_core::config::DataId, DoraNode, Event, IntoArrow};
fn main() -> eyre::Result<()> {
println!("hello");
let output = DataId::from("random".to_owned());
let (mut node, mut events) = DoraNode::init_from_env()?;
if events.recv_timeout(Duration::from_secs(100)).is_none() {
eprintln!("Evemt is None");
}
Ok(())
}With an empty input dataflow description, will return immediately instead of timing out on 100s.