def executar_fluxo_pendencias(ctx: dict, mensagem: str, atendimento_id: int = None) -> dict:
    """Executa o fluxo de verificação de pendências (busca APENAS /at)"""
    
    log("[FLUXO_PENDENCIAS] Executando verificação de pendências", "DEBUG")
    
    if not ctx.get("id_cliente"):
        return {"resposta": "Preciso identificar seu cadastro primeiro. Por favor, informe seu CPF."}
    
    if not ctx.get("contatos_confirmados"):
        return etapa_exibir_contatos(ctx)
    
    cadastros = ctx.get("ultima_consulta_cpf", [])
    id_cliente = ctx.get("id_cliente")
    
    cad = None
    for c in cadastros:
        if c.get("id_cliente") == id_cliente:
            cad = c
            break
    
    if not cad:
        return {"resposta": "Não foi possível localizar seus dados. Informe seu CPF novamente."}
    
    planos_ativos = filtrar_planos_ativos(cad.get("planos", []))
    
    if not planos_ativos:
        return {"resposta": "Não encontrei planos ativos no seu cadastro."}
    
    # Usar plano_id do contexto ou do primeiro plano
    plano_id = ctx.get("id_cliente_plano")
    if not plano_id:
        plano_id = planos_ativos[0].get("id_cliente_plano")
        ctx["id_cliente_plano"] = plano_id
        log(f"[FLUXO_PENDENCIAS] Usando plano_id: {plano_id}", "DEBUG")
    
    # Buscar APENAS cobranças em ATRASO
    resultado = chamar_api_radiusnet("cobrancas_plano_atraso", id_cliente_plano=plano_id)
    cobrancas_atraso = resultado.get("data", []) if resultado.get("success") else []
    log(f"[FLUXO_PENDENCIAS] Cobranças em atraso: {len(cobrancas_atraso)}", "DEBUG")
    
    if not cobrancas_atraso:
        # Limpar estado para permitir nova classificação
        ctx["intencao_definida"] = None
        return {
            "resposta": "✅ Não encontrei cobranças em atraso. Sua conta está em dia!\n\nDeseja falar com o setor Financeiro mesmo assim? (responda SIM ou NÃO)",
            "aguardando_confirmacao_financeiro": True
        }
    
    # Tem cobranças em atraso
    ctx["lista_cobrancas_atraso"] = cobrancas_atraso
    
    resposta = "⚠️ *Encontrei cobranças em atraso:*\n\n"
    for i, cob in enumerate(cobrancas_atraso, 1):
        periodo = cob.get("periodo_prestacao", "?")
        vencimento = formatar_data(cob.get("data_vencimento"))
        valor = formatar_valor(cob.get("valor_total_a_pagar"))
        resposta += f"{i} - Período: {periodo} - Vencimento: {vencimento} - Valor: {valor}\n"
    
    resposta += "\nO que deseja fazer?\n"
    resposta += "1 - Escolher uma cobrança para pagar (Pix, código ou PDF)\n"
    resposta += "2 - Falar com o setor Financeiro\n"
    resposta += "\nDigite o número da cobrança ou 2 para falar com o Financeiro."
    
    ctx["aguardando_escolha_cobranca_pendencias"] = True
    
    return {"resposta": resposta}