@@ -370,7 +370,6 @@ async fn evaluate_op_scope(
370370 AnalyzedReactiveOp :: Transform ( op) => {
371371 let transform_key = format ! ( "transform/{}{}" , op_scope. scope_qualifier, op. name) ;
372372
373- // Track transform operation start
374373 if let Some ( ref op_stats) = operation_in_process_stats {
375374 op_stats. start_processing ( & transform_key, 1 ) ;
376375 }
@@ -391,15 +390,14 @@ async fn evaluate_op_scope(
391390 let warn_handle = tokio:: spawn ( async move {
392391 tokio:: time:: sleep ( warn_duration) . await ;
393392 eprintln ! (
394- "⚠️ WARNING: Function '{}' ({}) is taking longer than 30s" ,
393+ "WARNING: Function '{}' ({}) is taking longer than 30s" ,
395394 op_kind_for_warning, op_name_for_warning
396- ) ; // ✅ Show both
395+ ) ;
397396 warn ! (
398397 "Function '{}' ({}) is taking longer than 30s" ,
399398 op_kind_for_warning, op_name_for_warning
400399 ) ;
401400 } ) ;
402- // Execute with timeout
403401 let result = if op. function_exec_info . enable_cache {
404402 let output_value_cell = memory. get_cache_entry (
405403 || {
@@ -418,7 +416,6 @@ async fn evaluate_op_scope(
418416 op. executor . evaluate ( input_values)
419417 } ) ;
420418
421- // Handle timeout
422419 let timeout_result = tokio:: time:: timeout ( timeout_duration, eval_future) . await ;
423420 if timeout_result. is_err ( ) {
424421 Err ( anyhow ! (
@@ -435,7 +432,6 @@ async fn evaluate_op_scope(
435432 } else {
436433 let eval_future = op. executor . evaluate ( input_values) ;
437434
438- // Handle timeout
439435 let timeout_result = tokio:: time:: timeout ( timeout_duration, eval_future) . await ;
440436 if timeout_result. is_err ( ) {
441437 Err ( anyhow ! (
@@ -453,7 +449,6 @@ async fn evaluate_op_scope(
453449
454450 warn_handle. abort ( ) ;
455451
456- // Track transform operation completion
457452 if let Some ( ref op_stats) = operation_in_process_stats {
458453 op_stats. finish_processing ( & transform_key, 1 ) ;
459454 }
0 commit comments