fix: Fixing Spark template to include source name (#2381)

Signed-off-by: Danny Chiao <danny@tecton.ai>
feast-dev · Mar 9, 2022 · e7a3b3f · e7a3b3f
1 parent 7a93152
commit e7a3b3f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/sdk/python/feast/templates/spark/example.py b/sdk/python/feast/templates/spark/example.py
@@ -23,12 +23,14 @@
 
 # Sources
 driver_hourly_stats = SparkSource(
+    name="driver_hourly_stats",
     path=f"{CURRENT_DIR}/data/driver_hourly_stats",
     file_format="parquet",
     event_timestamp_column="event_timestamp",
     created_timestamp_column="created",
 )
 customer_daily_profile = SparkSource(
+    name="customer_daily_profile",
     path=f"{CURRENT_DIR}/data/customer_daily_profile",
     file_format="parquet",
     event_timestamp_column="event_timestamp",