From 143dcba2ca70bc809fbab8f813d873c216b18530 Mon Sep 17 00:00:00 2001 From: TeoCalvo Date: Mon, 21 Aug 2023 18:16:10 +0000 Subject: [PATCH] fix table_nae as argument in function --- src/02.bronze/datasus/ingestao.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/02.bronze/datasus/ingestao.py b/src/02.bronze/datasus/ingestao.py index 7743363..67aaca0 100644 --- a/src/02.bronze/datasus/ingestao.py +++ b/src/02.bronze/datasus/ingestao.py @@ -29,7 +29,7 @@ # COMMAND ---------- # DBTITLE 1,Criação da tabela -if not dbtools.table_exists(spark, database_name, table): +if not dbtools.table_exists(spark, database_name, table_name): df_null = spark.createDataFrame(data=[], schema=ingestao.schema) ingestao.save_full(df_null) dbutils.fs.rm(ingestao.checkpoint_path, True)