| 883 | } |
| 884 | |
| 885 | async fn delete_mc_group(&mut self) -> Result<Option<(FuotaJob, DateTime<Utc>)>> { |
| 886 | // Proceed with next step after reaching the max attempts. |
| 887 | if self.job.attempt_count > self.job.max_retry_count { |
| 888 | return Ok(Some((FuotaJob::Complete, Utc::now()))); |
| 889 | } |
| 890 | |
| 891 | info!("Delete multicast group"); |
| 892 | self.job.attempt_count += 1; |
| 893 | |
| 894 | multicast::delete(&self.fuota_deployment.id).await?; |
| 895 | |
| 896 | Ok(Some((FuotaJob::Complete, Utc::now()))) |
| 897 | } |
| 898 | |
| 899 | async fn complete(&mut self) -> Result<Option<(FuotaJob, DateTime<Utc>)>> { |
| 900 | // Proceed with next step after reaching the max attempts. |