Create a new task
(self, task: Task)
| 1154 | |
| 1155 | # Task operations |
| 1156 | async def create_task(self, task: Task) -> int: |
| 1157 | """Create a new task""" |
| 1158 | async with self._connect(write=True) as db: |
| 1159 | cursor = await db.execute(""" |
| 1160 | INSERT INTO tasks (task_id, token_id, model, prompt, status, progress, scene_id) |
| 1161 | VALUES (?, ?, ?, ?, ?, ?, ?) |
| 1162 | """, (task.task_id, task.token_id, task.model, task.prompt, |
| 1163 | task.status, task.progress, task.scene_id)) |
| 1164 | await db.commit() |
| 1165 | return cursor.lastrowid |
| 1166 | |
| 1167 | async def get_task(self, task_id: str) -> Optional[Task]: |
| 1168 | """Get task by ID""" |