We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 40a4436 commit 5f087e2Copy full SHA for 5f087e2
terraform/account-wide-infrastructure/modules/glue/src/pipeline.py
@@ -89,9 +89,9 @@ def transform(self, dataframe):
89
def load(self, data):
90
"""Load transformed data into Parquet format"""
91
self.logger.info(f"Loading data into {self.target_path} as Parquet")
92
- if not data:
93
- return None
94
for name, dataframe in data.items():
+ if not dataframe:
+ return None
95
name = name.replace("--", "_")
96
dataframe.write.mode("append").partitionBy(*self.partition_cols).parquet(
97
f"{self.target_path}{name}"
0 commit comments