Skip to content

Commit e7a3b3f

Browse files
committed
fix: Fixing Spark template to include source name (#2381)
Signed-off-by: Danny Chiao <danny@tecton.ai>
1 parent 7a93152 commit e7a3b3f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

sdk/python/feast/templates/spark/example.py

+2
Original file line numberDiff line numberDiff line change
@@ -23,12 +23,14 @@
2323

2424
# Sources
2525
driver_hourly_stats = SparkSource(
26+
name="driver_hourly_stats",
2627
path=f"{CURRENT_DIR}/data/driver_hourly_stats",
2728
file_format="parquet",
2829
event_timestamp_column="event_timestamp",
2930
created_timestamp_column="created",
3031
)
3132
customer_daily_profile = SparkSource(
33+
name="customer_daily_profile",
3234
path=f"{CURRENT_DIR}/data/customer_daily_profile",
3335
file_format="parquet",
3436
event_timestamp_column="event_timestamp",

0 commit comments

Comments
 (0)