Skip to content

Commit 3b3d035

Browse files
committed
NRL-1346 Improved error handling
1 parent c129e38 commit 3b3d035

File tree

1 file changed

+4
-0
lines changed
  • terraform/account-wide-infrastructure/modules/glue/src

1 file changed

+4
-0
lines changed

terraform/account-wide-infrastructure/modules/glue/src/pipeline.py

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,10 @@ def load(self, data):
118118
if name == "s2c":
119119
name = "ssp"
120120
try:
121+
if dataframe.rdd.isEmpty():
122+
self.logger.info(f"{name} dataframe has no rows. Skipping.")
123+
continue
124+
121125
self.logger.info(
122126
f"Attempting to load dataframe {name} into {self.target_path}{name}"
123127
)

0 commit comments

Comments
 (0)