Skip to content

Commit 895ff2f

Browse files
committed
Insert different values with unique timestamps to allow fjall to insert multiple values
Signed-off-by: James Rhodes <[email protected]>
1 parent baf06ac commit 895ff2f

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

crates/extensions/tedge_flows/src/actor.rs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -119,7 +119,7 @@ impl FlowsMapper {
119119
match flow_messages {
120120
Ok(messages) => self.publish_messages(flow_id, timestamp, messages).await?,
121121
Err(err) => {
122-
error!(target: "flows", "{flow_id}: {err}");
122+
error!(target: "flows", "{flow_id}: {err:#}");
123123
}
124124
}
125125
}
@@ -187,6 +187,7 @@ impl FlowsMapper {
187187
FlowOutput::MeaDB { output_series } => {
188188
for message in messages {
189189
info!(target: "flows", "store {output_series} @{}.{} [{}] {}", timestamp.seconds, timestamp.nanoseconds, message.topic, message.payload);
190+
let timestamp = DateTime::now();
190191
if let Err(err) = self
191192
.processor
192193
.database

db_dump_sqlite

1.82 MB
Binary file not shown.

0 commit comments

Comments
 (0)