diff --git a/crates/churn/src/agent/agent_state.rs b/crates/churn/src/agent/agent_state.rs index 4e86669..ef71702 100644 --- a/crates/churn/src/agent/agent_state.rs +++ b/crates/churn/src/agent/agent_state.rs @@ -3,12 +3,8 @@ use std::{ops::Deref, sync::Arc}; use crate::api::Discovery; use super::{ - config::AgentConfig, - discovery_client::DiscoveryClient, - grpc_client::GrpcClient, - handlers::scheduled_tasks::{self, ScheduledTasks}, - queue::AgentQueue, - scheduler::Scheduler, + config::AgentConfig, discovery_client::DiscoveryClient, grpc_client::GrpcClient, + handlers::scheduled_tasks::ScheduledTasks, queue::AgentQueue, scheduler::Scheduler, }; #[derive(Clone)] diff --git a/crates/churn/src/agent/handlers/scheduled_tasks.rs b/crates/churn/src/agent/handlers/scheduled_tasks.rs index 574f46c..48df8e2 100644 --- a/crates/churn/src/agent/handlers/scheduled_tasks.rs +++ b/crates/churn/src/agent/handlers/scheduled_tasks.rs @@ -14,6 +14,8 @@ impl ScheduledTasks { task: &str, _properties: BTreeMap, ) -> anyhow::Result<()> { + tracing::info!("scheduling: {}", task); + // Get plan let plan = Plan::new(); let tasks = plan.tasks().await?; diff --git a/crates/churn/src/agent/queue.rs b/crates/churn/src/agent/queue.rs index 2ea9e72..305b427 100644 --- a/crates/churn/src/agent/queue.rs +++ b/crates/churn/src/agent/queue.rs @@ -3,7 +3,7 @@ use std::sync::Arc; use notmad::{Component, MadError}; use tokio::sync::Mutex; -use super::{handlers::scheduled_tasks::ScheduledTasks, models::Commands, scheduler::Scheduler}; +use super::{models::Commands, scheduler::Scheduler}; #[derive(Clone)] pub struct AgentQueue { diff --git a/crates/churn/src/agent/refresh.rs b/crates/churn/src/agent/refresh.rs index e87d4d7..79c271b 100644 --- a/crates/churn/src/agent/refresh.rs +++ b/crates/churn/src/agent/refresh.rs @@ -1,7 +1,5 @@ use std::collections::BTreeMap; -use anyhow::Context; - use crate::agent::models::Commands; use super::{agent_state::AgentState, queue::AgentQueue};