Update 02_load_raw.py

Author: sfc-gh-chammond

steps/02_load_raw.py

@@ -34,6 +34,9 @@ def load_raw_table(session, tname=None, s3dir=None, year=None, schema=None):
  df = session.read.option("compression", "snappy") \
  .parquet(location)
  df.copy_into_table("{}".format(tname))
+ comment_text = '''{"origin":"sf_sit-is","name":"snowpark_101_de","version":{"major":1, "minor":0},"attributes":{"is_quickstart":1, "source":"sql"}}'''
+ sql_command = f"""COMMENT ON TABLE {tname} IS '{comment_text}';"""
+ session.sql(sql_command).collect()
 
 # SNOWFLAKE ADVANTAGE: Warehouse elasticity (dynamic scaling)