mirror of
https://github.com/microsoft/onefuzz.git
synced 2025-06-16 20:08:09 +00:00
address clippy warnings from 0.1.54 (#1118)
This commit is contained in:
@ -85,7 +85,7 @@ impl ReportTask {
|
|||||||
info!("processing existing crashes");
|
info!("processing existing crashes");
|
||||||
if let Some(crashes) = &self.config.crashes {
|
if let Some(crashes) = &self.config.crashes {
|
||||||
self.poller
|
self.poller
|
||||||
.batch_process(&mut processor, &crashes)
|
.batch_process(&mut processor, crashes)
|
||||||
.await
|
.await
|
||||||
.context("batch processing failed")?;
|
.context("batch processing failed")?;
|
||||||
}
|
}
|
||||||
|
@ -286,7 +286,7 @@ impl Agent {
|
|||||||
Ok(None) => {}
|
Ok(None) => {}
|
||||||
Ok(Some(cmd)) => {
|
Ok(Some(cmd)) => {
|
||||||
info!("agent received node command: {:?}", cmd);
|
info!("agent received node command: {:?}", cmd);
|
||||||
self.scheduler()?.execute_command(&cmd).await?;
|
self.scheduler()?.execute_command(cmd).await?;
|
||||||
}
|
}
|
||||||
Err(PollCommandError::RequestFailed(err)) => {
|
Err(PollCommandError::RequestFailed(err)) => {
|
||||||
// If we failed to request commands, this could be the service
|
// If we failed to request commands, this could be the service
|
||||||
|
@ -121,7 +121,7 @@ pub async fn update(data: &ConfigData) -> Result<()> {
|
|||||||
if !path.is_file() {
|
if !path.is_file() {
|
||||||
info!("adding service {}", file_name);
|
info!("adding service {}", file_name);
|
||||||
tokio::fs::write(&path, content).await?;
|
tokio::fs::write(&path, content).await?;
|
||||||
start_service(&file_name).await?;
|
start_service(file_name).await?;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user