Update task dependencies in database.
(self, task_id: int, dependencies: List[int])
| 148 | return task_ids |
| 149 | |
| 150 | def _update_task_dependencies(self, task_id: int, dependencies: List[int]): |
| 151 | """Update task dependencies in database.""" |
| 152 | import json |
| 153 | self.state.execute( |
| 154 | "UPDATE task_queue SET dependencies = ? WHERE id = ?", |
| 155 | (json.dumps(dependencies), task_id), |
| 156 | ) |
| 157 | |
| 158 | def get_next_task(self) -> Optional[Task]: |
| 159 | """ |