Modified: CalendarServer/branches/users/glyph/sharedpool/txdav/base/datastore/asyncsqlpool.py (6501 => 6502)
--- CalendarServer/branches/users/glyph/sharedpool/txdav/base/datastore/asyncsqlpool.py 2010-11-01 21:14:49 UTC (rev 6501)
+++ CalendarServer/branches/users/glyph/sharedpool/txdav/base/datastore/asyncsqlpool.py 2010-11-01 21:15:01 UTC (rev 6502)
@@ -338,7 +338,7 @@
@ExecSQL.responder
@inlineCallbacks
- def sendSQL(self, transactionID, queryID, sql, args):
+ def receivedSQL(self, transactionID, queryID, sql, args):
norows = True
try:
rows = yield self._txns[transactionID].execSQL(sql, args)
@@ -348,6 +348,8 @@
if rows is not None:
for row in rows:
norows = False
+ # Either this should be yielded or it should be
+ # requiresAnswer=False
self.callRemote(Row, queryID=queryID, row=row)
self.callRemote(QueryComplete, queryID=queryID, norows=norows)
returnValue({})