Daily Digest

O Communication — Daily Digest pede a cada pessoa responsável, numa mensagem direta no Slack, as leituras de KPI devidas no dia. Toda manhã ele acha as Recurrence Configurations ativas cuja cadência vence, tira as leituras já registradas, agrupa o resto por membership responsável, acha a conta de Slack de cada pessoa em Tooling and Access, manda um digest com checkboxes por membership e registra cada tentativa como uma Message no Communication. As respostas voltam pelo workflow separado Communication — Reading Reply, que trata os checkboxes.

O maintainer de KPIs & OKRs cuida das agendas e da regra de vencimento; o maintainer do Communication revisa as linhas de Message; o maintainer de Tooling and Access mantém as pessoas ligadas às suas contas de Slack.

Fluxo

Gerado da versão do n8n do quadro acima: cada caixa é um nó e cada seta é uma ligação no n8n. Pílulas rosa são gatilhos, hexágonos amarelos são nós If e Switch com as saídas nas setas, cilindros azuis leem (Airtable, Data Table, HTTP GET), cilindros verdes gravam, caixas roxas chamam outro workflow e setas tracejadas são saídas de erro.

flowchart TD
  subgraph g0["Início e schema"]
    n6(["Every day 09:00"]):::trigger
    n33(["Webhook"]):::trigger
    n34(["When clicking ‘Execute workflow’"]):::trigger
    n4["Config"]:::logic
    n0["Airtable Schema"]:::logic
    n20[("Meta (Operation)<br/><small>getSchema KPIs base</small>")]:::read
    n19[("Meta (Communication)<br/><small>getSchema Communication base</small>")]:::read
    n21[("Meta (Tooling)<br/><small>getSchema Tooling base</small>")]:::read
    n27["Resolve Schema"]:::logic
    n30{{"Schema OK"}}:::decision
  end
  subgraph g1["Leituras devidas"]
    n17[("List Due Schedules<br/><small>search KPIs Recurrence Configuration</small>")]:::read
    n10[("Get Cadences<br/><small>search KPIs Cadence</small>")]:::read
    n3["Compute Due Items"]:::logic
    n16{{"Is OK"}}:::decision
    n1["Build Answered Filter"]:::logic
    n7[("Find Answered<br/><small>search KPIs Observation</small>")]:::read
    n14["Group by Recipient"]:::logic
    n15{{"Has Digests"}}:::decision
    n18["Log Nothing To Do"]:::logic
  end
  subgraph g2["Destinatário no Slack"]
    n13[("Get Slack Accounts<br/><small>search Tooling Tool Account</small>")]:::read
    n11[("Get Identity Bindings<br/><small>search Tooling Identity Binding</small>")]:::read
    n12[("Get Persons (Tooling)<br/><small>search Tooling Person</small>")]:::read
    n29["Resolve Slack Recipient"]:::logic
    n25{{"Recipient Resolved?"}}:::decision
    n9["Get Cached Notification Bot<br/><small>Slack — Workspace Token Cache</small>"]:::subflow
    n28["Resolve Slack Account"]:::logic
  end
  subgraph g3["Enviar e registrar"]
    n2["Build Slack Blocks"]:::logic
    n32{{"User Found"}}:::decision
    n22{{"Not Dry Run"}}:::decision
    n23[("Open DM<br/><small>POST Slack conversations.open</small>")]:::write
    n24[("Post Digest<br/><small>POST Slack chat.postMessage</small>")]:::write
    n8[("Find Membership (Communication)<br/><small>search Communication Membership</small>")]:::read
    n31["Shape Message Row"]:::logic
    n5[("Create Message<br/><small>create Communication Message</small>")]:::write
    n26["Report"]:::logic
  end
  n6 --> n4
  n4 --> n0
  n0 --> n20
  n20 --> n19
  n19 --> n21
  n21 --> n27
  n27 --> n30
  n17 --> n10
  n10 --> n3
  n3 --> n16
  n1 --> n7
  n7 --> n14
  n14 --> n15
  n13 --> n11
  n11 --> n12
  n12 --> n29
  n2 --> n32
  n23 --> n24
  n24 --> n8
  n8 --> n31
  n31 --> n5
  n5 --> n26
  n30 -->|sim| n17
  n30 -->|não| n18
  n16 -->|sim| n1
  n16 -->|não| n18
  n15 -->|sim| n13
  n15 -->|não| n18
  n32 -->|sim| n22
  n32 -->|não| n8
  n22 -->|sim| n23
  n22 -->|não| n8
  n34 --> n4
  n33 --> n4
  n29 --> n25
  n25 -->|sim| n9
  n25 -->|não| n28
  n9 --> n28
  n28 --> n2
  classDef trigger fill:#fde7f3,stroke:#d6409f,color:#111
  classDef decision fill:#fff7e0,stroke:#c99a00,color:#111
  classDef read fill:#e8f1ff,stroke:#3b82f6,color:#111
  classDef write fill:#e7f8ee,stroke:#16a34a,color:#111
  classDef subflow fill:#f3e8ff,stroke:#9333ea,color:#111
  classDef wait fill:#f1f1f1,stroke:#888,color:#111
  classDef logic fill:#ffffff,stroke:#999,color:#111

Sistemas que ele toca

Meta (Operation), Meta (Communication) e Meta (Tooling) também leem a lista de tabelas e campos das três bases. A linha de Message liga o Channel Slack DM e a Notification Rule Reading due today por ID de registro, e a tag kpis-okrs-daily-digest-n8n.

Fora do Airtable, o Get Cached Notification Bot chama o workflow Slack — Workspace Token Cache para obter o token do bot do workspace de cada destinatário, e Open DM e Post Digest chamam a Web API do Slack.

Os nós do Airtable são nós nativos do Airtable com a credencial Airtable PAT (Fully Scoped). Eles leem e gravam pelo nome da coluna, mas todo nome vem do Resolve Schema, que traduz a cada execução os IDs de campo guardados no Airtable Schema para os nomes atuais. Renomear uma coluna não quebra o fluxo; apagar uma o para no Schema OK.

Veja Daily Digest para o lado das leituras em KPIs & OKRs e Entrega do Daily Digest para as linhas de Message no Communication.

Gatilhos e agenda

Três gatilhos iniciam a mesma execução no Config:

O Config define as constantes da execução:

Conferência do schema

O Airtable Schema guarda os IDs de base, tabela e campo que o fluxo usa em KPIs & OKRs, Communication e Tooling and Access. Meta (Operation), Meta (Communication) e Meta (Tooling) leem o schema de cada base, e o Resolve Schema mapeia cada ID para o nome atual. Quando falta uma tabela ou campo, o Resolve Schema devolve “Schema drift — not found in Airtable: …” e o Schema OK manda a execução para o Log Nothing To Do, que a encerra.

Leituras devidas

1. Agendas. O List Due Schedules lê as Recurrence Configurations com Lifecycle Status* Active e um Cadence (Key). O Get Cadences lê o catálogo Cadence (mirror) inteiro.

2. Devidas hoje. O Compute Due Items pula a agenda cuja chave de cadência não está no catálogo, cuja cadência não está Active ou que não tem Accountable Membership*. Fica com as que vencem na data da execução:

   Chave da cadência	Vence quando
   daily	Todo dia
   daily-working-days	O dia da semana está no By Day da cadência
   weekly	Segunda-feira
   biweekly	Segunda-feira de semana ISO par
   monthly	Dia 1
   quarterly	Dia 1 de janeiro, abril, julho e outubro
   semiannual	Dia 1 de janeiro e julho
   annual	1º de janeiro
   on-demand, ou qualquer outra chave	Nunca

   Cada item devido ganha uma chave de período a partir do Period Key Format da cadência e uma chave de ocorrência <ID do registro da Recurrence Configuration>:<chave de período>. Os destinatários são as memberships responsáveis da agenda, com nome, e-mail, Membership # e organização. O nome vem do Accountable Display Name; quando ele é só um ID de registro, é tirado do Accountable (Membership #), que tem a forma “número - nome - organização”.

3. Já respondidas. O Build Answered Filter monta fórmulas de Occurrence Key em lotes de 40, e o Find Answered lê essas Observations. O Group by Recipient tira o item de uma membership quando uma Observation tem a mesma Occurrence Key, traz essa membership em Observation About (Membership)* e tem Collection Status* vazio ou Recorded.

4. Um digest por membership. O Group by Recipient agrupa o que sobrou por membership responsável, fica com os 25 primeiros itens e conta o resto como excedente. Um destinatário sem nome fica de lado como inalcançável. O Has Digests encerra a execução no Log Nothing To Do quando não sobra nada.

Destinatário no Slack

O Get Slack Accounts lê as Tool Accounts com Kind human (só Name, External Identifier, Kind e Workspace (External Identifier); nunca Access Token). Get Identity Bindings e Get Persons (Tooling) leem as duas tabelas inteiras. Para cada digest, o Resolve Slack Recipient:

1. acha a Person (mirror) cujo Full name* é igual ao nome do destinatário, ignorando maiúsculas e espaços extras;
2. fica com as Identity Bindings dessa pessoa cujo Valid Through está vazio ou no futuro, e com as Tool Accounts human delas;
3. escolhe a conta no workspace mapeado para a organização da membership; senão, a única conta; senão, a conta no workspace padrão;
4. confere que o ID do workspace começa com T e o ID do usuário do Slack com U.

Cada falha vira um erro no item (“Person not found in Tooling mirror: …”, “No Slack account bound to …”, “No Slack account for … in workspace …”, INVALID_WORKSPACE, INVALID_SLACK_USER). O Recipient Resolved? manda os itens resolvidos para o Get Cached Notification Bot, que roda o Slack — Workspace Token Cache com o ID do workspace, cacheOnly false, forceRefresh false e refreshAll false, e espera a resposta. O Resolve Slack Account só aceita a resposta quando ela está ok, é do mesmo workspace, traz token e ID de usuário do bot e não venceu; senão, o item recebe TOKEN_CACHE_UNAVAILABLE, TOKEN_WORKSPACE_MISMATCH ou TOKEN_CACHE_INVALID.

Enviar e registrar

O Build Slack Blocks monta o digest: um cabeçalho “<data> · 0 of N responses recorded”, depois seções de até 10 checkboxes com a ação reading_reply, um por leitura (nome, descrição, meta), cada um com o valor <chave de ocorrência>|<ID do registro da membership>|<ID do usuário no Slack>. O excedente acrescenta a linha “N additional readings are not shown in this message.”

Open DM e Post Digest usam a credencial do n8n Systems Slack Automation - Dynamic, que usa o token do bot resolvido para o item. O Find Membership (Communication) procura em Membership (mirror) pelo Membership # (igual, ou começando com “<número> - “). O Shape Message Row monta a linha e o Create Message a salva. O Report conta digests, enviados e falhos da execução.

Campos gravados

Message do Communication (Create Message)

O fluxo não grava mais nada: nenhuma Observation, nenhuma Recurrence Configuration e nada em Tooling and Access.

Nós

O workflow tem 36 nós: 35 que executam e uma nota adesiva. Num nó If, a saída 0 é verdadeiro e a saída 1 é falso.

Ligações

Configurações e tratamento de erro

Desde 06/11/2026 o n8n guarda toda execução deste workflow, com sucesso, com falha e manual, com progresso. Antes dessa data nada era guardado, então para execuções antigas as linhas de Message são o único registro.

Lacunas conhecidas

Estas vêm da configuração dos nós e das linhas de Message que o fluxo gravou.

Recuperar uma gravação parcial

Veja as linhas de Message da execução antes de iniciar outra: uma nova execução manda de novo para todos que têm algo sem resposta, e não há reenvio para um destinatário só.

Manter esta página em dia

O quadro no topo mostra a versão do n8n que esta página descreve. Abra o workflow no n8n: quando o último salvamento dele é mais novo que a data do quadro, esta página está desatualizada até a próxima revisão. Todos os nós e todas as ligações dessa versão estão em Nós e Ligações.