diff --git a/applications/rd_gen_to_dags/src/build_dag.rs b/applications/rd_gen_to_dags/src/build_dag.rs index 3eb6e364..b6af74ca 100644 --- a/applications/rd_gen_to_dags/src/build_dag.rs +++ b/applications/rd_gen_to_dags/src/build_dag.rs @@ -119,11 +119,6 @@ async fn register_source_node( let out_links_num = node_data.get_out_links().len(); - assert!( - out_links_num == 0, - "LinkNumError::NoInput: dag_id={dag_id}, node_id={node_id}" - ); - match out_links_num { 1 => register_source!(dag, node_data, sched_type, u64), 2 => register_source!(dag, node_data, sched_type, u64, u64), @@ -174,11 +169,6 @@ async fn register_sink_node( let in_links_num = node_data.get_in_links().len(); - assert!( - in_links_num == 0, - "LinkNumError::NoInput: dag_id={dag_id}, node_id={node_id}" - ); - match in_links_num { 1 => register_sink!(dag, node_data, sched_type, u64), 2 => register_sink!(dag, node_data, sched_type, u64, u64), @@ -242,19 +232,6 @@ async fn register_intermediate_node( let in_links_num = node_data.get_in_links().len(); let out_links_num = node_data.get_out_links().len(); - assert!( - in_links_num > 0 && out_links_num > 0, - "LinkNumError::NoInOut: dag_id={dag_id}, node_id={node_id}" - ); - assert!( - in_links_num == 0, - "LinkNumError::NoInput: dag_id={dag_id}, node_id={node_id}", - ); - assert!( - out_links_num == 0, - "LinkNumError::NoOutput: dag_id={dag_id}, node_id={node_id}", - ); - match (in_links_num, out_links_num) { (1, 1) => register_intermediate!(dag, node_data, sched_type, u64; u64), (1, 2) => register_intermediate!(dag, node_data, sched_type, u64; u64, u64), diff --git a/applications/rd_gen_to_dags/src/lib.rs b/applications/rd_gen_to_dags/src/lib.rs index ab06cdd6..606c2016 100644 --- a/applications/rd_gen_to_dags/src/lib.rs +++ b/applications/rd_gen_to_dags/src/lib.rs @@ -48,6 +48,11 @@ pub async fn run() { } } + if success_build_dags.is_empty() { + log::error!("Failed to build DAG"); + return; + } + match finish_create_dags(&success_build_dags).await { Ok(_) => { log::info!("DAGs created successfully.");