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)