fix: remove unnecessary wakes

Author: akundaz

src/pipelines/exec/mod.rs

@@ -301,9 +301,6 @@ where
 				}
 				trace!("{} initializing completed", executor.pipeline);
 			}
-
-			// tell the async runtime to poll again because we are still initializing
-			cx.waker().wake_by_ref();
 		}
 
 		// the pipeline has completed executing all steps or encountered and error.
@@ -340,9 +337,6 @@ where
 
 				return Poll::Ready(output);
 			}
-
-			// tell the async runtime to poll again because we are still finalizing
-			cx.waker().wake_by_ref();
 		}
 
 		if matches!(executor.cursor, Cursor::BeforeStep(_, _)) {
@@ -359,7 +353,6 @@ where
 			trace!("{} will execute step {path}", executor.pipeline);
 			let future = executor.execute_step(&path, input);
 			executor.cursor = Cursor::StepInProgress(path, future);
-			cx.waker().wake_by_ref(); // tell the async runtime to poll again
 		}
 
 		if let Cursor::StepInProgress(ref path, ref mut future) = executor.cursor {
@@ -374,8 +367,6 @@ where
 				// step has completed, we can advance the cursor
 				executor.cursor = executor.advance_cursor(path, output);
 			}
-
-			cx.waker().wake_by_ref(); // tell the async runtime to poll again
 		}
 
 		Poll::Pending