Add my silly functions for examining queue state
This commit is contained in:
1 parent
be6189bde0
commit
66695a5f0a
1 file changed
+15
@@ -1,5 +1,20 @@
|
||||
|
||||
|
||||
def h_q_dict(q, /):
|
||||
return dict(
|
||||
scheduled=(q.scheduled_count(), q.scheduled(),),
|
||||
pending=(q.pending_count(), q.pending(),),
|
||||
result=(q.result_count(), q.all_results(),),
|
||||
)
|
||||
|
||||
|
||||
def h_q_tuple(q, /):
|
||||
return (
|
||||
q.name,
|
||||
h_q_dict(q),
|
||||
)
|
||||
|
||||
|
||||
def sqlite_tasks(key, /, prefix=None):
|
||||
name_fmt = 'huey_{}'
|
||||
if prefix is None:
|
||||
|
||||
Reference in new issue
Block a user