diff --git a/apis/rust/node/src/event_stream/event.rs b/apis/rust/node/src/event_stream/event.rs index 3c0a49ce..2206f9fe 100644 --- a/apis/rust/node/src/event_stream/event.rs +++ b/apis/rust/node/src/event_stream/event.rs @@ -16,7 +16,7 @@ pub enum Event { }, Input { id: DataId, - metadata: Metadata<'static>, + metadata: Metadata, data: Option, }, InputClosed { diff --git a/apis/rust/node/src/node/control_channel.rs b/apis/rust/node/src/node/control_channel.rs index 7e44a2c1..f0d74a78 100644 --- a/apis/rust/node/src/node/control_channel.rs +++ b/apis/rust/node/src/node/control_channel.rs @@ -83,7 +83,7 @@ impl ControlChannel { pub fn send_message( &mut self, output_id: DataId, - metadata: Metadata<'static>, + metadata: Metadata, data: Option, ) -> eyre::Result<()> { let request = DaemonRequest::SendMessage { diff --git a/binaries/daemon/src/lib.rs b/binaries/daemon/src/lib.rs index 0f99de69..6efd311a 100644 --- a/binaries/daemon/src/lib.rs +++ b/binaries/daemon/src/lib.rs @@ -758,7 +758,7 @@ impl Daemon { dataflow_id: Uuid, node_id: NodeId, output_id: DataId, - metadata: dora_core::message::Metadata<'static>, + metadata: dora_core::message::Metadata, data: Option, ) -> Result<(), eyre::ErrReport> { let dataflow = self.running.get_mut(&dataflow_id).wrap_err_with(|| { @@ -1069,7 +1069,7 @@ async fn send_output_to_local_receivers( node_id: NodeId, output_id: DataId, dataflow: &mut RunningDataflow, - metadata: &dora_core::message::Metadata<'static>, + metadata: &dora_core::message::Metadata, data: Option, clock: &HLC, ) -> Result>, eyre::ErrReport> { @@ -1443,7 +1443,7 @@ pub enum DaemonNodeEvent { }, SendOut { output_id: DataId, - metadata: dora_core::message::Metadata<'static>, + metadata: dora_core::message::Metadata, data: Option, }, ReportDrop { @@ -1459,7 +1459,7 @@ pub enum DoraEvent { Timer { dataflow_id: DataflowId, interval: Duration, - metadata: dora_core::message::Metadata<'static>, + metadata: dora_core::message::Metadata, }, SpawnedNodeResult { dataflow_id: DataflowId, diff --git a/libraries/core/src/daemon_messages.rs b/libraries/core/src/daemon_messages.rs index 72fbda87..21fe9332 100644 --- a/libraries/core/src/daemon_messages.rs +++ b/libraries/core/src/daemon_messages.rs @@ -50,7 +50,7 @@ pub enum DaemonRequest { Subscribe, SendMessage { output_id: DataId, - metadata: Metadata<'static>, + metadata: Metadata, data: Option, }, CloseOutputs(Vec), @@ -152,7 +152,7 @@ pub enum NodeEvent { }, Input { id: DataId, - metadata: Metadata<'static>, + metadata: Metadata, data: Option, }, InputClosed { @@ -233,7 +233,7 @@ pub enum InterDaemonEvent { dataflow_id: DataflowId, node_id: NodeId, output_id: DataId, - metadata: Metadata<'static>, + metadata: Metadata, data: Option>, }, InputsClosed {