comment out inner handles so we are not abusive
@@ -216,7 +216,7 @@ from(bucket:"github_webhooks")
let client = self.clone();
let r = r.clone();
let handle = tokio::task::spawn(async move {
- let mut inner_handles: Vec<tokio::task::JoinHandle<()>> = Default::default();
+ //let mut inner_handles: Vec<tokio::task::JoinHandle<()>> = Default::default();
let commits = r
.commits()
.iter()
@@ -304,12 +304,12 @@ from(bucket:"github_webhooks")
client.query(push, EventType::Push.name()).await;
}
- let client = client.clone();
+ /*let client = client.clone();
let repo = repo.clone();
let r = r.clone();
let repo_name = repo_name.clone();
let reference = reference.clone();
- let inner_handle = tokio::task::spawn(async move {
+ let inner_handle = tokio::task::spawn(async move {*/
// Handle the check_suite events for each commit.
let check_suite_list_options = hubcaps::checks::CheckSuiteListOptions::builder().per_page(100).build();
let check_suites = match r.commits().list_check_suites(&commit_sha, &check_suite_list_options).await {
@@ -483,16 +483,16 @@ from(bucket:"github_webhooks")
}
}
}
- });
+ // });
// Add this handle to our stack of handles.
- inner_handles.push(inner_handle);
+ // inner_handles.push(inner_handle);
}
// Wait for all the handles.
- for inner_handle in inner_handles {
+ /* for inner_handle in inner_handles {
inner_handle.await.unwrap_or_else(|e| println!("[warn]: handle failed: {:#?}]", e));
- }
+ }*/
});
// Add this handle to our stack of handles.
