fix: clippy

paladin-core/src/directive/indexed_stream/mod.rs

@@ -190,7 +190,7 @@ where
 ///
 /// This is a passthrough implementation, which simply delegates to the inner
 /// stream.
-impl<'a, T> Stream for IndexedStream<'a, T> {
+impl<T> Stream for IndexedStream<'_, T> {
     type Item = Result<(usize, T)>;
 
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {

paladin-core/src/runtime/mod.rs

@@ -748,6 +748,8 @@ impl WorkerRuntime {
             // Create a future that will wait for an IPC termination signal.
             let ipc_sig_term = {
                 let mut ipc_sig_term_rx = ipc_sig_term_rx.clone();
+                let abort_worker_execution = abort_worker_execution.clone();
+                let routing_key = routing_key.clone();
                 async move {
                     loop {
                         ipc_sig_term_rx.changed().await.expect("IPC channel closed");

paladin-core/src/task/mod.rs

@@ -116,7 +116,7 @@ pub enum AnyTaskResult {
     Err(String),
 }
 
-impl<'a, Op: Operation, Metadata: Serializable> Task<'a, Op, Metadata> {
+impl<Op: Operation, Metadata: Serializable> Task<'_, Op, Metadata> {
     /// Convert a [`Task`] into an opaque [`AnyTask`].
     pub fn as_any_task(&self, serializer: Serializer) -> Result<AnyTask> {
         let routing_key = self.routing_key.clone();