Flyte项目中Map任务日志级别被固定为30的问题分析

在Flyte项目中发现了一个关于日志级别控制的特殊现象：当用户为默认日志记录器设置日志级别时，Python任务能够正确响应这个设置，但Map任务却会强制将日志级别固定在30（WARNING级别）。这个差异会导致开发者在使用Map任务时无法获取预期的INFO级别日志输出。

问题现象

通过一个简单的代码示例可以清晰重现这个问题：

import logging
from flytekit import task, workflow, map_task

# 设置全局日志级别为INFO
level = logging.INFO
logging.basicConfig(level=level)

@task
def my_task(s: str) -> str:
    logger = logging.getLogger()
    print(f"当前生效日志级别: {logger.getEffectiveLevel()}")

    # 测试日志输出
    logging.info("这是一条INFO日志")  # 期望输出
    logging.error("这是一条ERROR日志")  # 总是输出
    return s

@workflow
def wf():
    my_task(s='单次任务')  # 这里日志级别正常
    strings = ['任务1', '任务2']
    return map_task(my_task)(s=strings)  # 这里日志级别被固定为WARNING

当这个工作流执行时，会出现以下现象：

1. 直接调用的my_task会正确输出INFO和ERROR级别的日志
2. 通过map_task调用的相同任务却只会输出ERROR日志，INFO日志被抑制

技术背景

在Python的logging模块中，日志级别数值定义如下：

• DEBUG: 10
• INFO: 20
• WARNING: 30
• ERROR: 40
• CRITICAL: 50

Flyte框架在执行Map任务时，似乎对日志系统进行了特殊处理，导致默认日志记录器的级别被重置为WARNING(30)，而用户通过basicConfig设置的级别被忽略。

影响范围

这个问题会影响以下场景的开发体验：

1. 需要详细日志调试Map任务的场景
2. 依赖默认日志记录器统一管理日志级别的项目
3. 期望在不同任务类型间保持日志行为一致的场景

临时解决方案

目前可以通过创建非默认日志记录器来绕过这个问题：

logger = logging.getLogger("custom_logger")
logger.setLevel(logging.INFO)

使用自定义日志记录器可以确保在Map任务中获得预期的日志输出，但这增加了代码复杂度，不是理想的长期解决方案。

问题本质

这个问题反映了Flyte在Map任务执行环境初始化时，可能没有正确继承或保留用户配置的日志级别。从架构角度看，Map任务的执行可能发生在不同的上下文中，导致部分配置丢失。

建议的修复方向

理想的修复方案应该考虑：

1. 确保所有任务类型统一处理日志配置
2. 保留用户通过basicConfig设置的日志级别
3. 提供明确的日志级别覆盖机制

这个问题虽然不影响核心功能，但对于依赖日志进行调试和监控的用户来说会造成不便。希望Flyte团队能在后续版本中解决这个行为不一致的问题。

对于开发者来说，目前需要了解这个差异，在开发Map任务时特别注意日志配置，或者使用自定义日志记录器作为临时解决方案。