From 8f42c092b3839f1c62e629865d22e0635317d343 Mon Sep 17 00:00:00 2001 From: Ross Briden Date: Mon, 6 Mar 2023 14:37:31 -0700 Subject: [PATCH] init --- .../online_stores/contrib/mysql_online_store/mysql.py | 11 +++-------- setup.py | 2 +- 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/sdk/python/feast/infra/online_stores/contrib/mysql_online_store/mysql.py b/sdk/python/feast/infra/online_stores/contrib/mysql_online_store/mysql.py index 032786bc3f..c36be4fde4 100644 --- a/sdk/python/feast/infra/online_stores/contrib/mysql_online_store/mysql.py +++ b/sdk/python/feast/infra/online_stores/contrib/mysql_online_store/mysql.py @@ -115,11 +115,6 @@ def online_write_batch( val.SerializeToString(), timestamp, created_ts, - - # Update on duplicate key - val.SerializeToString(), - timestamp, - created_ts, ) ) @@ -134,9 +129,9 @@ def online_write_batch( (entity_key, feature_name, value, event_ts, created_ts) values (%s, %s, %s, %s, %s) ON DUPLICATE KEY UPDATE - value = %s, - event_ts = %s, - created_ts = %s; + value = values(value), + event_ts = values(event_ts), + created_ts = values(created_ts); """, insertion_batch ) diff --git a/setup.py b/setup.py index 34345787d4..76a8e0857d 100644 --- a/setup.py +++ b/setup.py @@ -40,7 +40,7 @@ from distutils.core import setup NAME = "feast" -VERSION = "0.28+affirm37" +VERSION = "0.28+affirm39" DESCRIPTION = "Python SDK for Feast" URL = "https://github.com/feast-dev/feast" AUTHOR = "Feast"