@@ -110,6 +110,7 @@ class Query(JidSet): key = str(eid) + "@" + jid conn.send_html_deduped(jid, plain, html, key) + @models.db_mutexed @models.wants_session def _deferred_write(self, theId, session): t=session.query(models.Track).filter_by(query=self.query).one() @@ -228,6 +229,7 @@ class UserStuff(JidSet): self._format_message('friend', entry, results) return f + @models.db_mutexed @models.wants_session def _deferred_write(self, jid, mprop, new_val, session): u = models.User.by_jid(jid, session) lib/twitterspy/scheduling.py 1f27c0ea9e25cc4a92f6af09ef61ac188e10f02c Dustin Sallings dustin@spy.net http://github.com/dustin/twitterspy/commit/cec228fc4f11354c75a2e9192b0ae236d34f3a30 cec228fc4f11354c75a2e9192b0ae236d34f3a30 2009-02-18T19:15:43-08:00 2009-02-18T19:14:19-08:00 Lock for async writes in the scheduled tasks. 108167232d7f0b8744efc909adf12107804af79f Dustin Sallings dustin@spy.net