MarshalDiskQueue bug fix

This commit is contained in:
Pablo Hoffman 2011-08-05 17:06:31 -03:00
parent 1ce84046d8
commit 38e193d480
1 changed files with 3 additions and 1 deletions

View File

@ -12,4 +12,6 @@ class MarshalDiskQueue(DiskQueue):
super(MarshalDiskQueue, self).push(marshal.dumps(obj))
def pop(self):
return marshal.loads(super(MarshalDiskQueue, self).pop())
s = super(MarshalDiskQueue, self).pop()
if s:
return marshal.loads(s)