diff --git a/ddtelemetry/src/worker/mod.rs b/ddtelemetry/src/worker/mod.rs
index 77a9cb0247..2051f94ff0 100644
--- a/ddtelemetry/src/worker/mod.rs
+++ b/ddtelemetry/src/worker/mod.rs
@@ -241,10 +241,10 @@ impl TelemetryWorker {
             Lifecycle(Start) => {
                 if !self.data.started {
                     self.deadlines
-                        .schedule_event(LifecycleAction::FlushData)
+                        .schedule_event(LifecycleAction::FlushMetricAggr)
                         .unwrap();
                     self.deadlines
-                        .schedule_event(LifecycleAction::FlushMetricAggr)
+                        .schedule_event(LifecycleAction::FlushData)
                         .unwrap();
                     self.data.started = true;
                 }
@@ -265,9 +265,6 @@ impl TelemetryWorker {
                     .unwrap();
             }
             Lifecycle(FlushData) => {
-                if !self.data.started {
-                    return CONTINUE;
-                }
                 let batch = self.build_observability_batch();
                 if !batch.is_empty() {
                     let payload = data::Payload::MessageBatch(batch);
@@ -296,7 +293,9 @@ impl TelemetryWorker {
                     self.log_err(&e);
                 }
                 self.data.started = false;
-                self.deadlines.clear_pending();
+                if !self.config.restartable {
+                    self.deadlines.clear_pending();
+                }
                 return BREAK;
             }
             CollectStats(stats_sender) => {
@@ -341,10 +340,10 @@ impl TelemetryWorker {
                         Err(err) => self.log_err(&err),
                     }
                     self.deadlines
-                        .schedule_event(LifecycleAction::FlushData)
+                        .schedule_event(LifecycleAction::FlushMetricAggr)
                         .unwrap();
                     self.deadlines
-                        .schedule_event(LifecycleAction::FlushMetricAggr)
+                        .schedule_event(LifecycleAction::FlushData)
                         .unwrap();
                     self.data.started = true;
                 }
@@ -368,9 +367,6 @@ impl TelemetryWorker {
                     .unwrap();
             }
             Lifecycle(FlushData) => {
-                if !self.data.started {
-                    return CONTINUE;
-                }
                 let mut batch = self.build_app_events_batch();
                 let payload = if batch.is_empty() {
                     data::Payload::AppHeartbeat(())
@@ -458,7 +454,9 @@ impl TelemetryWorker {
                 .await;
 
                 self.data.started = false;
-                self.deadlines.clear_pending();
+                if !self.config.restartable {
+                    self.deadlines.clear_pending();
+                }
                 return BREAK;
             }
             CollectStats(stats_sender) => {