Change flush to commit for other db sessions to query (#967)

AudiusProject · Oct 23, 2020 · 2ddbc1d · 2ddbc1d
1 parent e079f39
commit 2ddbc1d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/discovery-provider/src/tasks/index.py b/discovery-provider/src/tasks/index.py
@@ -230,7 +230,7 @@ def index_blocks(self, db, blocks_list):
             # social state changes are not factored in since they don't affect track_lexeme_dict
             # write out all pending transactions to db before refreshing view
             track_lexeme_state_changed = (user_state_changed or track_state_changed)
-            session.flush()
+            session.commit()
             if user_state_changed:
                 session.execute("REFRESH MATERIALIZED VIEW user_lexeme_dict")
                 if user_ids: