fix: parquet not found on ingester (openobserve#7024)

Author: hengfeiyang

src/job/files/parquet.rs

@@ -556,6 +556,7 @@ async fn move_files(
         for file in new_file_list.iter() {
             // use same lock to combine the operations of check lock and add to removing list
             let wal_lock = infra::local_lock::lock("wal").await?;
+            let lock_guard = wal_lock.lock().await;
             let can_delete = if wal::lock_files_exists(&file.key) {
                 log::warn!(
                     "[INGESTER:JOB:{thread_id}] the file is in use, set to pending delete list: {}",
@@ -577,7 +578,7 @@ async fn move_files(
                 db::file_list::local::add_removing(&file.key).await?;
                 true
             };
-            drop(wal_lock);
+            drop(lock_guard);
 
             if can_delete {
                 match remove_file(wal_dir.join(&file.key)) {

src/service/search/grpc/wal.rs

@@ -558,6 +558,7 @@ async fn get_file_list_inner(
 
     // use same lock to combine the operations of filter by pending delete and lock files
     let wal_lock = infra::local_lock::lock("wal").await?;
+    let lock_guard = wal_lock.lock().await;
 
     // filter by pending delete
     let files = crate::service::db::file_list::local::filter_by_pending_delete(files).await;
@@ -567,7 +568,7 @@ async fn get_file_list_inner(
 
     // lock theses files
     wal::lock_files(&files);
-    drop(wal_lock);
+    drop(lock_guard);
 
     let stream_params = Arc::new(StreamParams::new(
         &query.org_id,