Get task from database
(self, task_id)
| 564 | conn.close() |
| 565 | |
| 566 | def get_task(self, task_id): |
| 567 | """Get task from database""" |
| 568 | conn = sqlite3.connect(self.db_file) |
| 569 | cursor = conn.cursor() |
| 570 | cursor.execute('SELECT * FROM tasks WHERE task_id = ?', (task_id,)) |
| 571 | row = cursor.fetchone() |
| 572 | conn.close() |
| 573 | |
| 574 | if row: |
| 575 | return { |
| 576 | 'task_id': row[0], |
| 577 | 'blob': row[1], |
| 578 | 'status': row[2], |
| 579 | 'token': row[3], |
| 580 | 'suppressed_answer': row[4], |
| 581 | 'pow_solution': row[5], |
| 582 | 'created_at': row[6], |
| 583 | 'completed_at': row[7], |
| 584 | 'error': row[8] |
| 585 | } |
| 586 | return None |
| 587 | |
| 588 | def update_task(self, task_id, status, token=None, suppressed_answer=None, pow_solution=None, error=None): |
| 589 | """Update task status""" |