Skip to content

Commit a8d50d7

Browse files
committed
remove assert
1 parent f64994d commit a8d50d7

File tree

2 files changed

+2
-8
lines changed

2 files changed

+2
-8
lines changed

locustdb-serialization/src/event_buffer.rs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -232,13 +232,6 @@ impl EventBuffer {
232232
.reborrow()
233233
.init_columns(table.columns.len() as u32);
234234
for (j, (colname, column)) in table.columns.iter().enumerate() {
235-
assert!(
236-
column.data.len() == table.len as usize || column.data.len() == 0,
237-
"Column {} has length {} but table has length {}",
238-
colname,
239-
column.data.len(),
240-
table.len,
241-
);
242235
let mut column_builder = columns.reborrow().get(j as u32);
243236
column_builder.set_name(colname);
244237
match &column.data {

wandb_data_import.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
print("Starting...")
1919
i = 0
20+
logger = locustdb.Client(url="http://localhost:8080")
2021
while True:
2122
try:
2223
run = next(runs)
@@ -33,7 +34,7 @@
3334
for row in run.history(pandas=False):
3435
clean_row = {k: v or 0.0 for k, v in row.items() if not isinstance(v, dict) and not isinstance(v, str)}
3536
# print(clean_row)
36-
locustdb.log(table=run.name, metrics=clean_row)
37+
logger.log(table="gb_9a43be3e-"+run.name, metrics=clean_row)
3738
rows += 1
3839
print(f"Logged {rows} rows")
3940
i += 1

0 commit comments

Comments
 (0)