Fix airflow2.x not show log in helpdesk (#101)

douban · Nov 19, 2021 · f97c79c · f97c79c
1 parent e4d1eaf
commit f97c79c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/helpdesk/libs/airflow.py b/helpdesk/libs/airflow.py
@@ -188,7 +188,7 @@ def get_task_result(self, dag_id, execution_date, task_id, try_number=None):
             all_task_result[task_id] = self._check_resp(
                 task_result, AirflowClientTaskResultException, 'Get task result {} error: {{}}'.format(task_id))
             if try_number:
-                all_task_result[task_id]['message'] = [all_task_result[task_id]['message']]
+                all_task_result[task_id]['message'] = [all_task_result[task_id]['message'][0][1]]
                 all_task_result[task_id]['pretty_log'] = [all_task_result[task_id]['pretty_log']]
         except AirflowClientTaskResultException as e:
             logger.error(f'Get {task_id} @ {execution_date} of {dag_id} error: {str(e)}')