Pueue

Filtering

Failure

Default

pueue status -g now -- columns=id,status,command status=failed

JSON

pueue status -g now -j | jq '.tasks[] | select(.status.Done? and (.status.Done.result | type) == "object" and (.status.Done.result | has("Failed")))  | .id'

Success

Default

pueue status -g now -- columns=id,status,command status=failed

JSON

pueue status -g now -j | jq '.tasks[] | select(.status.Done? and (.status.Done.result | type) == "string" and (.status.Done.result == "Success"))  | .id'

Queued

Default

pueue status -g now -- columns=id,status,command status=queued

JSON

pueue status -j | jq '.tasks[] | select(.status | has("Queued")) | .id'

Running

Default

pueue status -g now -- columns=id,status,command status=running

JSON

pueue status -j | jq '.tasks[] | select(.status | has("Running")) | .id'

PQ Helpers

Filtering

Find tasks that resulted in an increase in file size

pq log -g now --lines 1000  |& grep -E 'Task [0-9]+|≈' | grep -B 1 -F '0.'

Show filename for tasks that resulted in an increase in file size

pq log -g now --lines 1000  |& grep -E 'Task [0-9]+|≈' | grep -B 1 -F '0.' | grep Task | awk -F : '{ print $1 }' | awk '{ print $3 }' | xargs -n 1 pq log --lines 1

Get files a pq helper operated on, that resulted in a certain ratio

$ while read -r f; do unescaped="$(echo -n "$f" | python -c 'import shlex; _in=input(); print(shlex.split(_in)[0])')"; ls -alh "Favorite Tools.bck/$unescaped" "Favorite Tools/$unescaped"; done < <(pq log -g now --lines 1000  |& grep -E 'Task [0-9]+|≈'  | grep -B 1 -E '1\.(0|1|2)' | grep Task | awk -F : '{ print $1 }' | awk '{ print $3 }' | xargs -n 1 pq log --lines 1 |& grep Command | sed "s#.*32 ##")
-rw-r--r-- 1 florian.sorko staff 27M Feb  2 06:06 'Favorite Tools.bck/./065 Tested Favorite Tools： Hot Wire Foam Carving Set!.mp4'
-rw-r--r-- 1 florian.sorko staff 24M Feb  2 06:37 'Favorite Tools/./065 Tested Favorite Tools： Hot Wire Foam Carving Set!.mp4'
...

Run a command once the queue is empty

while true; do queued="$(pueue status -j | jq '.tasks[] | select(.status | has("Queued")) | .id' | wc -l)"; echo "$(dt): Queued tasks: $queued"; if [ "$queued" -gt 0 ]; then sleep 200; else break; fi; done ; rsync --dry-run  xyz