Merge pull request #25 from CoLearn-Dev/registry-fixes

- registry fixes
CoLearn-Dev · Aug 17, 2022 · 7e4299e · 7e4299e
2 parents 8b78730 + 8e53874
commit 7e4299e
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git 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
@@ -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;
             }
         }