Skip to content

Commit

Permalink
ci: trigger
Browse files Browse the repository at this point in the history
  • Loading branch information
leo-the-nardo committed Nov 9, 2024
1 parent b669d5f commit 2fb90a2
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion spark-jobs/brazilian-finder/brazilian-finder_spark.py
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ def spark_job(spark: SparkSession, params, *args, **kwargs):
try:
spark.read.format("delta").load(s3_master_combo_path)
except Exception as e:
# If the path does not exist, create an empty Delta table
# If the path does not exist, create an empty Delta table
empty_df = spark.createDataFrame([], schema="email_tel STRING")
empty_df.write.format("delta").save(s3_master_combo_path)
# Append the matching emails to the master delta table
Expand Down

0 comments on commit 2fb90a2

Please sign in to comment.