Execução e Agendamento

Uma vez que seu Dataflow esteja publicado em uma Mesa de Dados, você pode definir quando e como ele será executado.

---

▶️ Execução Manual (Forçar Carga)

Dispare uma execução manualmente a qualquer momento — ideal para cargas iniciais ou reprocessamento.

1. Na listagem da Mesa de Dados, clique no botão Executar ao lado do fluxo
2. O sistema apresentará opções dependendo de como o fluxo foi desenhado

Modos de Carga

Se o seu fluxo utiliza parâmetros temporais (variáveis {StartDate}, {EndDate}), o seletor de modo será exibido:

Modo	Descrição
Total	Executa o fluxo sem filtros de tempo. Ideal para carga histórica completa — apaga os dados antigos e recarrega tudo
Temporal	Permite definir um período específico: Dias Passados, Dias Futuros, Mês e Ano ou Ano
Incremental	Baseada em coluna de controle (updated_at), traz apenas registros novos ou alterados. O sistema guarda automaticamente o último datapoint processado

NOTE

Para que o modo Temporal funcione, seus nós (SQL Query, API Request) devem utilizar as variáveis {StartDate} e {EndDate}. Exemplo: DATA_EMISSAO BETWEEN '{StartDate}' AND '{EndDate}'

NOTE

Para que o modo Incremental funcione, seus nós devem utilizar a variável {LastDataPoint}. Exemplo: UPDATED_AT > '{LastDataPoint}'

---

⏰ Agendamentos

O Agendamento é o sistema de automação do Horus — ele dispara o fluxo automaticamente em intervalos definidos.

1. Acesse o menu Agendamentos (na barra lateral ou botão "Relógio" no card do fluxo)
2. Clique em Criar novo Agendamento
3. Configure a periodicidade ("Todo dia às 03:00 AM")
4. Vincule o fluxo que deve ser executado
5. Ative o agendamento

Status e Monitoramento

Na tela de Agendamentos, monitore as execuções:

Status	Indicador	Descrição
Sucesso	🟢	Terminou sem erros
Erro Parcial	🟡	Terminou, mas algumas linhas ou etapas falharam
Erro	🔴	O fluxo falhou e parou antes de concluir

Sequenciando Múltiplos Flows

Crie agendamentos com múltiplos flows em sequência para garantir a ordem de execução — essencial para arquiteturas em camadas:

1. Ao criar o agendamento, adicione os flows na ordem desejada
2. O sistema executa na sequência definida (RAW primeiro, depois Refined)
3. Se um flow anterior falhar, os posteriores não são executados

Exemplo de sequência típica:

1. raw_vendas — Extrai dados brutos do ERP
2. refined_vendas — Trata, remove duplicatas, aplica regras de negócio
3. gold_vendas — Gera agregações finais para dashboard

TIP

Configure o período de carga (últimos 30 dias) para cada flow, mantendo o mesmo período para flows do mesmo dado (vendas, por exemplo).