(&mut self, task: ScheduledTask)
| 533 | } |
| 534 | |
| 535 | async fn dispatch_scheduled_task(&mut self, task: ScheduledTask) { |
| 536 | info!("dispatching scheduled task"); |
| 537 | let task_id = task.id; |
| 538 | let evt = runtime_models::internal::tasks::ScheduledTask::from(task); |
| 539 | let serialized = serde_json::to_value(&evt).unwrap(); |
| 540 | self.dispatch_worker_evt( |
| 541 | "BOTLOADER_SCHEDULED_TASK_FIRED".to_string(), |
| 542 | serialized, |
| 543 | PendingAckType::ScheduledTask(task_id), |
| 544 | EventSource::Timer, |
| 545 | Utc::now(), |
| 546 | ) |
| 547 | .await; |
| 548 | } |
| 549 | |
| 550 | async fn dispatch_interval_timer(&mut self, timer: IntervalTimer) { |
| 551 | info!("dispatching interval timer"); |
no test coverage detected