diff --git a/sdk/python/feast/sdk/importer.py b/sdk/python/feast/sdk/importer.py index 0a86f481203..04fe1ec9a1b 100644 --- a/sdk/python/feast/sdk/importer.py +++ b/sdk/python/feast/sdk/importer.py @@ -291,8 +291,8 @@ def dump(self, path): def _convert_timestamp(df, timestamp_col): """Converts the given df's timestamp column to ISO8601 format """ - df[timestamp_col] = pd.to_datetime(df[timestamp_col]).dt \ - .strftime("%Y-%m-%dT%H:%M:%S%zZ") + df[timestamp_col] = pd.to_datetime(df[timestamp_col]) \ + .apply(lambda dt: dt.isoformat()) def _properties(source, size, require_staging, remote):