Skip to content

J
jumpserver
Commit f802fb64 authored by ibuler's avatar ibuler
Browse files
Options

[Update] Add debug message

parent 0b405fde
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 1 deletion
apps/ops/ws.py
View file @ f802fb64
...@@ -41,6 +41,7 @@ class CeleryLogWebsocket(JsonWebsocketConsumer): ...@@ -41,6 +41,7 @@ class CeleryLogWebsocket(JsonWebsocketConsumer):
def read_log_file(self, task_id): def read_log_file(self, task_id):
task_log_f = self.wait_util_log_path_exist(task_id) task_log_f = self.wait_util_log_path_exist(task_id)
if not task_log_f: if not task_log_f:
logger.debug('Task log file is None: {}'.format(task_id))
return return
task_end_mark = [] task_end_mark = []
...@@ -49,7 +50,8 @@ class CeleryLogWebsocket(JsonWebsocketConsumer): ...@@ -49,7 +50,8 @@ class CeleryLogWebsocket(JsonWebsocketConsumer):
if data: if data:
data = data.replace(b'\n', b'\r\n') data = data.replace(b'\n', b'\r\n')
self.send_json( self.send_json(
{'message': data.decode(errors='ignore'), 'task': task_id}) {'message': data.decode(errors='ignore'), 'task': task_id}
)
if data.find(b'succeeded in') != -1: if data.find(b'succeeded in') != -1:
task_end_mark.append(1) task_end_mark.append(1)
if data.find(bytes(task_id, 'utf8')) != -1: if data.find(bytes(task_id, 'utf8')) != -1:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment