From f641f2cdc8fdbf6b706829d6f44b18396b5e27df Mon Sep 17 00:00:00 2001 From: haixuanTao Date: Mon, 11 Mar 2024 20:36:21 +0100 Subject: [PATCH] Adding first row of data --- libraries/extensions/dora-record/src/main.rs | 3 +++ 1 file changed, 3 insertions(+) diff --git a/libraries/extensions/dora-record/src/main.rs b/libraries/extensions/dora-record/src/main.rs index 17ff8345..fb10bf18 100644 --- a/libraries/extensions/dora-record/src/main.rs +++ b/libraries/extensions/dora-record/src/main.rs @@ -85,6 +85,9 @@ async fn main() -> eyre::Result<()> { } writer.close().await }); + tx.send((data.into(), metadata)) + .await + .context("Could not send event data into writer loop")?; writers.insert(id, (tx, join_handle)); } Some((tx, _)) => {