Skip to content

Commit de5726f

Browse files
committed
Tolerate JSON null in memoization_info field in DB.
1 parent 4d18b85 commit de5726f

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/execution/db_tracking.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@ pub type TrackedTargetKeyForSource = Vec<(i32, Vec<TrackedTargetKey>)>;
1111
pub struct SourceTrackingInfo {
1212
pub max_process_ordinal: i64,
1313
pub staging_target_keys: sqlx::types::Json<TrackedTargetKeyForSource>,
14-
pub memoization_info: Option<sqlx::types::Json<MemoizationInfo>>,
14+
pub memoization_info: Option<sqlx::types::Json<Option<MemoizationInfo>>>,
1515

1616
pub processed_source_ordinal: Option<i64>,
1717
pub process_logic_fingerprint: Option<Vec<u8>>,

src/execution/indexer.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -445,6 +445,7 @@ pub async fn update_source_entry<'a>(
445445
let already_exists = existing_tracking_info.is_some();
446446
let memoization_info = existing_tracking_info
447447
.map(|info| info.memoization_info.map(|info| info.0))
448+
.flatten()
448449
.flatten();
449450
let evaluation_cache = memoization_info
450451
.map(|info| EvaluationCache::from_stored(info.cache))

0 commit comments

Comments
 (0)