We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8d2a09d commit d6c58bcCopy full SHA for d6c58bc
1 file changed
scripts/jobs/planning/tascomi_create_daily_snapshot.py
@@ -389,6 +389,7 @@ def purge_today_partition(
389
finally:
390
if len(dq_errors) > 0:
391
logger.error(f"Errors: {dq_errors}")
392
- raise Exception(f"Job Failed: {'; '.join(dq_errors)}")
+ spark.stop()
393
+ raise SystemExit(f"Failed: {'; '.join(dq_errors)}")
394
spark.sparkContext._gateway.close()
395
spark.stop()
0 commit comments