diff --git a/Cargo.lock b/Cargo.lock
index 060d31c..cdc25c9 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -417,7 +417,7 @@ dependencies = [
 
 [[package]]
 name = "colink-server"
-version = "0.1.8"
+version = "0.1.9"
 dependencies = [
  "async-trait",
  "base64 0.13.0",
diff --git a/Cargo.toml b/Cargo.toml
index 4729f4a..1642b43 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "colink-server"
-version = "0.1.8"
+version = "0.1.9"
 edition = "2021"
 
 [dependencies]
diff --git a/src/service/task.rs b/src/service/task.rs
index 6a20a6b..8c349d8 100644
--- a/src/service/task.rs
+++ b/src/service/task.rs
@@ -443,7 +443,7 @@ impl crate::server::MyService {
                     protocol_param: payload,
                     participants: vec![Participant {
                         user_id: user_id.to_string(),
-                        role: "query".to_string(),
+                        role: "query_from_registries".to_string(),
                     }],
                     require_agreement: false,
                     status: "started".to_string(),
@@ -468,10 +468,10 @@ impl crate::server::MyService {
                 self.add_task_new_status(user_id, &local_task).await?;
                 drop(task_storage_mutex);
             }
-            // We choose 1 second as the retry interval and retry 30 times.
+            // We choose 1 second as the retry interval and retry 60 times.
             tokio::time::sleep(tokio::time::Duration::from_secs(1)).await;
             counter += 1;
-            if counter > 30 {
+            if counter > 60 {
                 break;
             }
         }