chk
/
AppFlowy-Cloud
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'main' into feat/single-file-upload-limit

This commit is contained in:
Zack Fu Zi Xiang 2024-08-26 16:55:30 +08:00
parent 6adf8f0fb2 248834651b
commit c2e768bc30
No known key found for this signature in database
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
services/appflowy-collaborate/src/indexer/provider.rs
View File

@ -64,7 +64,7 @@ impl IndexerProvider {
fn get_unindexed_collabs( fn get_unindexed_collabs(
&self, &self,
) -> Pin<Box<dyn Stream<Item = Result<UnindexedCollab, anyhow::Error>>>> { ) -> Pin<Box<dyn Stream<Item = Result<UnindexedCollab, anyhow::Error>> + Send>> {
let db = self.db.clone(); let db = self.db.clone();
Box::pin(try_stream! { Box::pin(try_stream! {
let collabs = get_collabs_without_embeddings(&db).await?; let collabs = get_collabs_without_embeddings(&db).await?;

9
services/appflowy-collaborate/src/rt_server.rs
View File

@ -1,11 +1,10 @@
use anyhow::Result;
use dashmap::mapref::entry::Entry;
use dashmap::DashMap;
use std::future::Future; use std::future::Future;
use std::pin::Pin; use std::pin::Pin;
use std::sync::{Arc, Weak}; use std::sync::{Arc, Weak};
use std::time::Duration; use std::time::Duration;
use anyhow::Result;
use dashmap::mapref::entry::Entry;
use dashmap::DashMap;
use tokio::sync::Notify; use tokio::sync::Notify;
use tokio::time::interval; use tokio::time::interval;
use tracing::{error, info, trace}; use tracing::{error, info, trace};
@ -254,7 +253,7 @@ where
} }
fn spawn_handle_unindexed_collabs(indexer_provider: Arc<IndexerProvider>) { fn spawn_handle_unindexed_collabs(indexer_provider: Arc<IndexerProvider>) {
tokio::task::spawn_local(IndexerProvider::handle_unindexed_collabs(indexer_provider)); tokio::spawn(IndexerProvider::handle_unindexed_collabs(indexer_provider));
} }
fn spawn_period_check_inactive_group<S, AC>( fn spawn_period_check_inactive_group<S, AC>(