要更改Airflow中单个任务的颜色,可以按照以下步骤进行操作:
在Airflow的安装目录下,找到airflow/config_templates/airflow_local_settings.py
文件。如果该文件不存在,则可以创建一个新的文件。
在airflow_local_settings.py
文件中添加以下代码:
from airflow.www import utils as wwwutils
def task_instance_details(self, ti):
"""Override the task instance details to change the color for specific tasks"""
task = ti.task
color = None
# 设置特定任务的颜色
if task.task_id == 'task1':
color = 'blue'
elif task.task_id == 'task2':
color = 'green'
# 使用默认颜色(黑色)作为回退选项
if color is None:
color = 'black'
return color, task
# 将修改后的方法应用到Airflow中
wwwutils.TaskInstanceDetailsView.task_instance_details = task_instance_details
保存并关闭airflow_local_settings.py
文件。
重新启动Airflow服务。
现在,当你查看任务实例的详细信息时,特定任务(例如task1
和task2
)的颜色将会被更改为所定义的颜色(例如蓝色和绿色)。其他任务将保持默认的黑色颜色。