Skip to content

Commit 4a5034f

Browse files
committed
fix: removing created cast function
1 parent a3d9501 commit 4a5034f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/bronze/python/incremental_load.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -92,7 +92,7 @@ def full_initial_ingestion(spark: SparkSession, table: str, jdbc_url:str, MYSQL_
9292
.option("driver", "com.mysql.cj.jdbc.Driver") \
9393
.option("dbtable", query) \
9494
.load()
95-
df = df.withColumn("created", F.date_format("created", "yyyy-MM-dd'T'HH:mm:ss.SSSSSS"))
95+
#df = df.withColumn("created", F.date_format("created", "yyyy-MM-dd'T'HH:mm:ss.SSSSSS"))
9696
df = add_ingestion_metadata_column(df=df,table=table)
9797

9898

0 commit comments

Comments
 (0)