处理不足 batch_size 的片段

This commit is contained in:
kura 2026-05-01 17:25:56 +08:00
parent 38a94d0d87
commit 1348364aa3

View File

@ -285,6 +285,7 @@ async fn run_pipeline(
// Close channel to signal translation worker to flush and finish // Close channel to signal translation worker to flush and finish
drop(segment_tx); drop(segment_tx);
drop(seg_tx_for_callback);
if let Some(handle) = translate_join_handle { if let Some(handle) = translate_join_handle {
handle.await.unwrap_or_else(|join_error| { handle.await.unwrap_or_else(|join_error| {
eprintln!("translation worker panicked: {join_error:?}"); eprintln!("translation worker panicked: {join_error:?}");