updated celery logging info

This commit is contained in:
Marvin Zhang
2019-03-19 13:06:35 +08:00
parent bc1a2b2db1
commit bbdec7c61e

View File

@@ -72,6 +72,10 @@ def execute_spider(self, id: str):
# save task when the task is finished
db_manager.update_one('tasks', id=task_id, values={
'start_ts': datetime.now(),
'node_id': hostname,
'hostname': hostname,
'log_file_path': log_file_path,
'finish_ts': datetime.now(),
'status': status
})