modified task status update logic

This commit is contained in:
Marvin Zhang
2019-03-13 12:55:19 +08:00
parent 5e8ee66f70
commit e22f5dc5a5

View File

@@ -272,10 +272,7 @@ class SpiderApi(BaseApi):
spider_id = item['spider_id']
spider = db_manager.get('spiders', id=str(spider_id))
item['spider_name'] = spider['name']
task = db_manager.get('tasks_celery', id=item['_id'])
if task is not None:
item['status'] = task['status']
else:
if item.get('status') is None:
item['status'] = TaskStatus.UNAVAILABLE
return {
'status': 'ok',