diff --git a/file_store/src/file_info_poller.rs b/file_store/src/file_info_poller.rs index 078c49443..c9c33fba1 100644 --- a/file_store/src/file_info_poller.rs +++ b/file_store/src/file_info_poller.rs @@ -429,7 +429,7 @@ impl FileInfoPollerState for sqlx::Pool { .bind(process_name) .bind(file_type) .bind(MAX_SIZE_OF_FILES_PROCESSED_TABLE - 1) - .fetch_one(self) + .fetch_optional(self) .await .map_err(Error::from) }