Also check payloads when committing

Signed-off-by: Ryan Bottriell <rbottriell@ilm.com>
spkenv · Feb 27, 2024 · dd57cca · dd57cca
1 parent 5a53f60
commit dd57cca
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/crates/spfs/src/commit.rs b/crates/spfs/src/commit.rs
@@ -252,7 +252,11 @@ where
                 let node = node.into_owned();
                 let fut = async move {
                     let entry = &node.entry;
-                    if self.repo.has_object(entry.object).await {
+                    let (has_object, has_payload) = tokio::join!(
+                        self.repo.has_object(entry.object),
+                        self.repo.has_payload(entry.object),
+                    );
+                    if has_object && has_payload {
                         return Ok(CommitBlobResult::AlreadyExists(node));
                     }
                     let created = if entry.is_symlink() {