revert materialized view changes

Author: davidgamez

functions-python/helpers/database.py

@@ -152,17 +152,13 @@ def close_db_session(session, raise_exception: bool = False):
             raise error
 
 
-def refresh_materialized_view(session, view_name: str, concurrently=True) -> bool:
+def refresh_materialized_view(session, view_name: str) -> bool:
     """
     Refresh Materialized view by name.
     @return: True if the view was refreshed successfully, False otherwise
     """
     try:
-        session.execute(
-            text(
-                f"REFRESH MATERIALIZED VIEW {'CONCURRENTLY' if concurrently else ''} {view_name}"
-            )
-        )
+        session.execute(text(f"REFRESH MATERIALIZED VIEW CONCURRENTLY {view_name}"))
         return True
     except Exception as error:
         logging.error(f"Error raised while refreshing view: {error}")

functions-python/operations_api/src/feeds_operations/impl/feeds_operations_impl.py

@@ -151,7 +151,8 @@ async def _update_feed(
                     else update_request_feed.operational_status_action
                 )
                 session.add(feed)
-                refreshed = refresh_materialized_view(session, t_feedsearch.name, False)
+                session.flush()
+                refreshed = refresh_materialized_view(session, t_feedsearch.name)
                 logging.info(
                     f"Materialized view {t_feedsearch.name} refreshed: {refreshed}"
                 )
@@ -170,6 +171,7 @@ async def _update_feed(
             logging.error(
                 f"Failed to update feed ID: {update_request_feed.id}. Error: {e}"
             )
+            session.rollback()
             if isinstance(e, HTTPException):
                 raise e
             raise HTTPException(status_code=500, detail=f"Internal server error: {e}")