Skip to content

Commit bd7660c

Browse files
committed
test: update executor and WAL catchup tests for bitemporal scan fields
Set `system_as_of_ms: None` and `valid_at_ms: None` on all `TimeseriesOp::Scan` plan literals in the timeseries, tenant isolation, tenant purge, and WAL catchup integration tests to match the updated physical plan struct.
1 parent fbd0bb0 commit bd7660c

4 files changed

Lines changed: 16 additions & 0 deletions

File tree

nodedb/tests/executor_tests/test_tenant_isolation_timeseries.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,6 +48,8 @@ fn timeseries_scan_isolated() {
4848
aggregates: vec![],
4949
gap_fill: String::new(),
5050
rls_filters: vec![],
51+
system_as_of_ms: None,
52+
valid_at_ms: None,
5153
computed_columns: vec![],
5254
}),
5355
);
@@ -74,6 +76,8 @@ fn timeseries_scan_isolated() {
7476
aggregates: vec![],
7577
gap_fill: String::new(),
7678
rls_filters: vec![],
79+
system_as_of_ms: None,
80+
valid_at_ms: None,
7781
computed_columns: vec![],
7882
}),
7983
);

nodedb/tests/executor_tests/test_tenant_purge.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,8 @@ fn purge_removes_all_tenant_data() {
189189
aggregates: vec![],
190190
gap_fill: String::new(),
191191
rls_filters: vec![],
192+
system_as_of_ms: None,
193+
valid_at_ms: None,
192194
computed_columns: vec![],
193195
}),
194196
);

nodedb/tests/executor_tests/test_timeseries.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,8 @@ fn ts_scan(
7676
aggregates,
7777
gap_fill: String::new(),
7878
rls_filters: Vec::new(),
79+
system_as_of_ms: None,
80+
valid_at_ms: None,
7981
computed_columns: Vec::new(),
8082
}),
8183
);
@@ -112,6 +114,8 @@ fn ts_scan_filtered(
112114
aggregates,
113115
gap_fill: String::new(),
114116
rls_filters: Vec::new(),
117+
system_as_of_ms: None,
118+
valid_at_ms: None,
115119
computed_columns: Vec::new(),
116120
}),
117121
);
@@ -688,6 +692,8 @@ fn large_group_by_returns_single_valid_json() {
688692
aggregates: vec![("count".into(), "*".into())],
689693
gap_fill: String::new(),
690694
rls_filters: Vec::new(),
695+
system_as_of_ms: None,
696+
valid_at_ms: None,
691697
computed_columns: Vec::new(),
692698
}),
693699
);

nodedb/tests/wal_catchup.rs

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,8 @@ impl TestStack {
111111
aggregates: vec![("count".into(), "*".into())],
112112
gap_fill: String::new(),
113113
rls_filters: Vec::new(),
114+
system_as_of_ms: None,
115+
valid_at_ms: None,
114116
computed_columns: Vec::new(),
115117
}),
116118
collection,
@@ -494,6 +496,8 @@ fn startup_replay_recovers_all_wal_data() {
494496
aggregates: vec![("count".into(), "*".into())],
495497
gap_fill: String::new(),
496498
rls_filters: Vec::new(),
499+
system_as_of_ms: None,
500+
valid_at_ms: None,
497501
computed_columns: Vec::new(),
498502
});
499503

0 commit comments

Comments
 (0)