We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b865d75 commit c39c168Copy full SHA for c39c168
src/bronze/get_full_tables.py
@@ -49,6 +49,7 @@ def add_date_partition_columns(df: DataFrame,column_name:str) -> DataFrame:
49
df = df.withColumn("year", F.year(F.col(column_name)))\
50
.withColumn("month", F.month(F.col(column_name)))\
51
.withColumn("day",F.day(column_name))
52
+ return df
53
54
def main() -> None:
55
MYSQL_DATABASE = get_required_env("MYSQL_DATABASE")
0 commit comments