Merge pull request #44 from sfc-gh-chammond/patch-1

Add tags to table for tracking

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)