...
...
'''
'''
now = datetime.utcnow()
now = datetime.utcnow()
# Queries to find all matching subscription objects
# Queries to find all matching subscription objects
q_direct = dict(
q_direct = dict(
type='direct',
type='direct',
queue={'$ne':[]},
queue_empty=False,
queue_empty=False,
)
)
if MAILBOX_QUIESCENT:
if MAILBOX_QUIESCENT:
q_direct['last_modified']={'$lt':now - MAILBOX_QUIESCENT}
q_direct['last_modified']={'$lt':now - MAILBOX_QUIESCENT}
q_digest = dict(
q_digest = dict(