Execução / Run ao vivo

pro0036 — risco IRRBB

Executando
CT
Christopher T.Migration Lead
desconectado

Nova migração

Jobs

conecte e selecione uma licença…

Detalhe do job

Log de execução

selecione um job…
RUN ID
20260618_pro0036
ROTA
sas-to-databricks
AGENTE
Codex CLI · v0.4.4
DESTINO
Databricks · job 1068874463569336
INÍCIO
há 12m · ETA ~4m
PROGRESSO GERAL · 18 / 25 unidades

Pipeline da unidade step_019

PROC SQL · agregação de exposiçãoRepair · tentativa 2/4
01 · Analyzeunidade + lineage
02 · ConvertPySpark gerado
03 · Executerodando no destino
04 · Repairstacktrace + histórico
05 · Validatemétricas SAS×DBX
06 · Auditevidência por run
Circuit breaker: 2 tentativas restantes Progresso entre tentativas: detectado ✓

Unidades · 25

18 ok·2 review
step_001%macro setup
ok
step_002DATA STEP — base
ok
step_003PROC SORT
ok
step_011%macro não reconhecida
review
step_018PROC MEANS
ok
step_019PROC SQL — exposição
repair 2/4
step_020DATA STEP — flags
queued
step_021PROC TRANSPOSE
queued
step_022PROC SQL — join final
queued
step_025main() — e-mail
queued

Reparo da unidade step_019

SAS 9.4 · origem
1  proc sql;
2    create table work.exposicao as
3    select cd_cliente,
4           sum(vl_exposicao) as vl_total,
5           put(dt_ref, yymmddn8.) as dt
6    from origem.posicao
7    group by cd_cliente, calculated dt;
8  quit;
PySpark · tentativa 2
1  # migratemind-step:step_019
2  exposicao = (origem_posicao
3    .groupBy("cd_cliente",
+      F.date_format("dt_ref", "yyyyMMdd").alias("dt"))
5    .agg(F.sum("vl_exposicao")
6           .alias("vl_total")))
-  exposicao = exposicao.withColumn("dt", F.col("dt_ref"))
8  exposicao.write.saveAsTable("work.exposicao")
Stacktrace capturado no destino (tentativa 1)
AnalysisException: cannot resolve 'dt_ref' given input columns:
  [cd_cliente, vl_total]; line 7 pos 24
  at org.apache.spark.sql.catalyst.analysis...

Histórico de tentativas

Convert — PySpark inicial gerado12:02:14 · 1.8s · 412 tok
Execute → erro AnalysisException: dt_ref12:02:51 · runtime error
Repair tentativa 1 prompt fix_runtime_error12:03:09 · 2.1s · 690 tok
Repair tentativa 2 re-executando no destino…agora

Log de execução

live
12:03:09 INFO  repair_loop: building fix_runtime_error
12:03:09 DEBUG context: prev 18 validated steps attached
12:03:11 INFO  codex: response parsed (1 python block)
12:03:12 INFO  notebook: cell step_019 replaced
12:03:12 INFO  databricks: submitting job run…
12:03:18 WARN  spark: shuffle partitions auto-tuned
12:03:21 OK    step_019 wrote work.exposicao (8 cols)
12:03:21 INFO  validate: comparing SAS×DBX metrics…