Python异步函数因定义位置不同返回类型异常求助

我编写了异步函数async def get_all_distinct_identifications()，遇到异常情况：

• 当该函数定义在CarelinePeopleService类内部时，调用await CareLinePeopleService().enrolled_people_list_in_care_lines()的返回值为tuple，而非预期的Pandas DataFrame；即便改用self调用，结果仍为tuple。
• 但将该函数定义在其他文件中时，能正常返回Pandas DataFrame。

怀疑是Python底层机制导致此问题，请教原因。

相关代码如下：

异常场景下的get_all_distinct_identifications（类内部定义时） #

async def get_all_distinct_identifications(insurer_id, trigger_type, conditional_type, conditionals_fields):
    df_conditionals = await ConditionalsService().get_from_conditional_table(
        insurer_id=insurer_id,
        trigger_type=trigger_type,
        conditional_type=conditional_type,
        fields=conditionals_fields,
        care_lines=[],
    )

    df_of_people_identified = await CareLinePeopleService().enrolled_people_list_in_care_lines(
        df_care_line=df_conditionals[['care_line_id']].drop_duplicates().reset_index(drop=True),
        identifications=None,
        limit=1000,
        offset=None
    )

    return df_of_people_identified

CareLinePeopleService.enrolled_people_list_in_care_lines定义 #

async def enrolled_people_list_in_care_lines(self, df_care_line, identifications=None, limit=1000, offset=None):
    if type(offset) == int:
        df_people_identified = await self.get_batch_of_enrolled_people_by_care_line_id(df_care_line, limit, offset)
    elif identifications is not None:
        df_people_identified = await self.get_new_enrolled_people_in_care_lines(identifications)
    else:
        df_people_identified = await self.get_all_enrolled_people_in_care_lines(df_care_line)

    return df_people_identified

内部调用的三个子方法定义 #

async def get_batch_of_enrolled_people_by_care_line_id(self, df_care_line, limit, offset):
    list_of_care_line_id = list(df_care_line['care_line_id'].drop_duplicates().astype(str))
    query = CareLinePeopleRepository.enrolled_people_list_in_care_lines(
        list_of_care_line_id=list_of_care_line_id,
        limit=limit,
        offset=offset
    )
    df_of_people_identified = await Mysql().execute_to_pd(query)

    return df_of_people_identified

async def get_new_enrolled_people_in_care_lines(self, identifications):
    list_of_care_line_id = list(identifications['care_line_id'].drop_duplicates().astype(str))
    identifications_list = list(identifications[['person_id', 'care_line_id']].drop_duplicates().itertuples(index=False, name=None))
    query = CareLinePeopleRepository.enrolled_people_list_in_care_lines(
        list_of_care_line_id=list_of_care_line_id,
        identifications_list=identifications_list
    )
    df_of_people_identified = await Mysql().execute_to_pd(query)

    return df_of_people_identified

async def get_all_enrolled_people_in_care_lines(self, df_care_line):
    list_of_care_line_id = list(df_care_line['care_line_id'].drop_duplicates().astype(str))
    query = CareLinePeopleRepository.enrolled_people_list_in_care_lines(
        list_of_care_line_id=list_of_care_line_id
    )
    df_of_people_identified = await Mysql().execute_to_pd(query)

    return df_of_people_identified

从现象来看，问题核心是函数定义位置（类内/类外）导致同一个异步方法返回值类型不一致，排除业务逻辑本身的差异后，以下是几个高概率的原因：

1. 类内部方法名冲突/覆盖 #

检查CareLinePeopleService类中是否存在同名的非异步方法enrolled_people_list_in_care_lines。Python中同名方法会直接覆盖，若存在一个同步的def enrolled_people_list_in_care_lines()且返回tuple，当你在类内部调用时，可能因定义顺序问题，实际调用的是这个同步方法而非异步版本。

2. 循环导入导致类定义不完整 #

如果CareLinePeopleService所在模块与get_all_distinct_identifications依赖的模块存在循环导入（比如类内部导入了某个使用该类的模块，反之亦然），会导致Python加载类时部分方法定义未完全初始化，此时调用enrolled_people_list_in_care_lines可能返回默认占位值（如tuple）而非预期的DataFrame。

3. Mysql.execute_to_pd的上下文差异 #

检查Mysql类的实现细节：

• 类内部调用时，是否存在同名属性self.Mysql覆盖了全局的Mysql类，导致使用了不同的数据库实例？
• execute_to_pd方法是否在错误场景下返回tuple（比如(结果码, 错误信息)），而类内部调用触发了这些错误（如数据库连接参数、权限问题）但异常被静默处理？

4. 异步方法的装饰器或代理干扰 #

如果CareLinePeopleService的方法使用了装饰器（如ORM异步装饰器、日志装饰器），这些装饰器在类内部和外部的行为可能不同，导致返回值被包装成tuple（比如装饰器将返回值与执行时间等额外信息打包返回）。

• 打印type(CareLinePeopleService().enrolled_people_list_in_care_lines)，确认是否为异步函数类型（coroutine function）。
• 在enrolled_people_list_in_care_lines的三个分支中添加打印，确认实际进入的分支及df_people_identified的类型。
• 在类内部和外部分别打印Mysql().execute_to_pd(query)的返回值，排查是否存在差异。
• 排查模块间的循环导入问题，可通过打印模块的__file__属性确认加载顺序。

内容的提问来源于stack exchange，提问作者Jafet Henrique Guerra Fagundes