more debug lines, remove telemetry for agents

backend/src/main.rs

@@ -535,14 +535,16 @@ Windmill Community Edition {GIT_VERSION}
         };
 
         let instance_name = rd_string(8);
-        schedule_stats(
-            instance_name,
-            mode.clone(),
-            &db,
-            &HTTP_CLIENT,
-            cfg!(feature = "enterprise"),
-        )
-        .await;
+        if mode != Mode::Agent {
+            schedule_stats(
+                instance_name,
+                mode.clone(),
+                &db,
+                &HTTP_CLIENT,
+                cfg!(feature = "enterprise"),
+            )
+            .await;    
+        }
 
         futures::try_join!(shutdown_signal, workers_f, monitor_f, server_f, metrics_f)?;
     } else {

backend/windmill-worker/src/worker.rs

@@ -1372,6 +1372,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
         #[cfg(feature = "prometheus")]
         if let Some(wk) = worker_busy.as_ref() {
             wk.set(0);
+            tracing::debug!("set worker busy to 0");
         }
 
         #[cfg(feature = "prometheus")]
@@ -1381,6 +1382,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
                     .try_into()
                     .unwrap(),
             );
+            tracing::debug!("set uptime metric");
         }
 
         if last_ping.elapsed().as_secs() > NUM_SECS_PING {
@@ -1398,6 +1400,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
                 tracing::error!("failed to update worker ping, exiting: {}", e);
                 killpill_tx.send(()).unwrap_or_default();
             }
+            tracing::debug!("set last ping");
 
             last_ping = Instant::now();
         }
@@ -1425,6 +1428,7 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
                     break
                 },
                 Some(job_id) = same_worker_rx.recv() => {
+                    tracing::debug!("received {job_id} from same worker channel");
                     sqlx::query_as::<_, QueuedJob>("SELECT * FROM queue WHERE id = $1")
                     .bind(job_id)
                     .fetch_optional(db)
@@ -1493,13 +1497,17 @@ pub async fn run_worker<R: rsmq_async::RsmqConnection + Send + Sync + Clone + 's
         #[cfg(feature = "prometheus")]
         if let Some(wb) = worker_busy.as_ref() {
             wb.set(1);
+            tracing::debug!("set worker busy to 1");
         }
 
+
         match next_job {
             Ok(Some(job)) => {
                 last_executed_job = None;
                 jobs_executed += 1;
 
+                tracing::debug!(worker = %worker_name, "started handling of job {}", job.id);
+
                 if matches!(job.job_kind, JobKind::Script | JobKind::Preview) {
                     if !dedicated_workers.is_empty() {
                         let key_o = if is_flow_worker {