diff --git a/skills/fabric-lakehouse/references/pyspark.md b/skills/fabric-lakehouse/references/pyspark.md index 9c68c9a2..8eae36e4 100644 --- a/skills/fabric-lakehouse/references/pyspark.md +++ b/skills/fabric-lakehouse/references/pyspark.md @@ -136,7 +136,7 @@ VACUUM silver_transactions RETAIN 168 HOURS ### Incremental Load Pattern ```python -from pyspark.sql.functions import col, max as spark_max +from pyspark.sql.functions import col # Get last processed watermark last_watermark = spark.sql("""