fix: Fixing the return order of elements when calculating the min and max entity-DF event timestamps in the Spark offline store.

levpickis · levpickis · commit b181bde67b52 · 2022-04-25T18:33:51.000+03:00
Signed-off-by: Lev Pickovsky &lt;lev.pickovsky@ironsrc.com&gt;
diff --git a/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py b/sdk/python/feast/infra/offline_stores/contrib/spark_offline_store/spark.py
@@ -324,8 +324,8 @@ def _get_entity_df_event_timestamp_range(
         df = spark_session.sql(entity_df).select(entity_df_event_timestamp_col)
         # TODO(kzhang132): need utc conversion here.
         entity_df_event_timestamp_range = (
-            df.agg({entity_df_event_timestamp_col: "max"}).collect()[0][0],
             df.agg({entity_df_event_timestamp_col: "min"}).collect()[0][0],
+            df.agg({entity_df_event_timestamp_col: "max"}).collect()[0][0],
         )
     else:
         raise InvalidEntityType(type(entity_df))
