Coverage for mindsdb / interfaces / tasks / task.py: 45%

1from mindsdb.interfaces.storage import db 

2 

3 

4class BaseTask: 

5 

6 def __init__(self, task_id, object_id): 

7 self.task_id = task_id 

8 self.object_id = object_id 

9 

10 def run(self, stop_event): 

11 raise NotImplementedError 

12 

13 def set_error(self, message): 

14 task_record = db.Tasks.query.get(self.task_id) 

15 task_record.last_error = str(message) 

16 db.session.commit()