diff --git a/main.py b/main.py index 077b99d..2d4b5a7 100644 --- a/main.py +++ b/main.py @@ -114,6 +114,12 @@ async def update_nav(data: list[dict]): execute_values(cursor, query, values) conn.commit() logger.info('Update NAV was called and db update succeeded') + + with conn.cursur() as cursor: + cursor.execute('refresh materialized view latest_nav') + conn.commit() + logger.info('Latest NAV materialized view refreshed') + return {'message': "Database updated succesfully"} except Exception as e: logger.exception(f"Update Db errored out: {e}")