refresh latest NAV MV

This commit is contained in:
Gourav Kumar 2026-08-12 08:13:14 +05:30
parent 9f64d9e787
commit 837c3840d1

View File

@ -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}")