fixup! Make sinks a variant of collections

MaterializeInc · Feb 6, 2025 · d045a42 · d045a42
1 parent 3002944
commit d045a42
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/src/storage-client/src/controller.rs b/src/storage-client/src/controller.rs
@@ -740,12 +740,12 @@ impl<T: Timestamp> ExportState<T> {
         cluster_id: StorageInstanceId,
         read_hold: ReadHold<T>,
         self_hold: ReadHold<T>,
+        write_frontier: Antichain<T>,
         read_policy: ReadPolicy<T>,
     ) -> Self
     where
         T: Lattice,
     {
-        let write_frontier = Antichain::from_elem(Timestamp::minimum());
         let mut dependency_since = Antichain::from_elem(T::minimum());
         for read_hold in [&read_hold, &self_hold] {
             dependency_since.join_assign(read_hold.since());

diff --git a/src/storage-controller/src/lib.rs b/src/storage-controller/src/lib.rs
@@ -954,6 +954,7 @@ where
                         desc.instance_id,
                         read_hold,
                         self_hold,
+                        write_frontier.clone(),
                         ReadPolicy::step_back(),
                     );
                     maybe_instance_id = Some(state.cluster_id);