fix: Fix cancellation flow in python component graph (ai-dynamo#765)

pankajroark · web-flow · commit 420b7a82be51 · 2025-04-21T16:07:49.000-04:00
diff --git a/lib/bindings/python/rust/lib.rs b/lib/bindings/python/rust/lib.rs
@@ -697,6 +697,7 @@ async fn process_stream(
         // Send the PyObject through the channel or log an error
         if let Err(e) = tx.send(annotated).await {
             tracing::error!("Failed to send response: {:?}", e);
+            break;
         }
 
         if is_error {

Original file line number	Diff line number	Diff line change
`@@ -697,6 +697,7 @@ async fn process_stream(`
`697`	`697`	`// Send the PyObject through the channel or log an error`
`698`	`698`	`if let Err(e) = tx.send(annotated).await {`
`699`	`699`	`tracing::error!("Failed to send response: {:?}", e);`
	`700`	`+ break;`
`700`	`701`	`}`
`701`	`702`
`702`	`703`	`if is_error {`