(&self, task_id: &str)
| 475 | } |
| 476 | |
| 477 | pub async fn delete_comment_task(&self, task_id: &str) -> Result<()> { |
| 478 | let tasks_table = self.tasks_table().await?; |
| 479 | tasks_table |
| 480 | .delete(&format!("task_id = '{}'", escape_literal(task_id))) |
| 481 | .await |
| 482 | .context("failed to delete comment task")?; |
| 483 | |
| 484 | let task_filter = format!("task_id = '{}'", escape_literal(task_id)); |
| 485 | self.published_table() |
| 486 | .await? |
| 487 | .delete(&task_filter) |
| 488 | .await |
| 489 | .context("failed to delete related published comments")?; |
| 490 | self.audit_table() |
| 491 | .await? |
| 492 | .delete(&task_filter) |
| 493 | .await |
| 494 | .context("failed to delete related audit logs")?; |
| 495 | self.ai_runs_table() |
| 496 | .await? |
| 497 | .delete(&task_filter) |
| 498 | .await |
| 499 | .context("failed to delete related ai runs")?; |
| 500 | self.ai_chunks_table() |
| 501 | .await? |
| 502 | .delete(&task_filter) |
| 503 | .await |
| 504 | .context("failed to delete related ai chunks")?; |
| 505 | Ok(()) |
| 506 | } |
| 507 | |
| 508 | pub async fn upsert_published_comment( |
| 509 | &self, |
no test coverage detected