Skip to content

Commit eee2f0a

Browse files
committed
NRL-1320 Log if df is null
1 parent 96a5e28 commit eee2f0a

File tree

1 file changed

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

1 file changed

+2
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,6 +95,8 @@ def load(self, data):
9595
dataframe.write.mode("append").partitionBy(
9696
*self.partition_cols
9797
).parquet(f"{self.target_path}{name}")
98+
else:
99+
self.logger.info(f"Dataframe {name} is null, skipping")
98100

99101
def trigger_crawler(self):
100102
self.glue.start_crawler(Name=f"{self.name_prefix}-log-crawler")

0 commit comments

Comments
 (0)