diff options
| author | metamuffin <metamuffin@disroot.org> | 2025-05-18 12:45:12 +0200 |
|---|---|---|
| committer | metamuffin <metamuffin@disroot.org> | 2025-05-18 12:45:12 +0200 |
| commit | 0669d3871297abae36f0456e0d0042bf861afce8 (patch) | |
| tree | d5bfaeb96020ca0611595b629d444cbdbca45b42 /scripts/enqueue.ts | |
| parent | 4271431d21840f5b84bb238babc8e80fca638d2a (diff) | |
| download | isda-0669d3871297abae36f0456e0d0042bf861afce8.tar isda-0669d3871297abae36f0456e0d0042bf861afce8.tar.bz2 isda-0669d3871297abae36f0456e0d0042bf861afce8.tar.zst | |
complete tasks from files
Diffstat (limited to 'scripts/enqueue.ts')
| -rw-r--r-- | scripts/enqueue.ts | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/scripts/enqueue.ts b/scripts/enqueue.ts index e6e3958..934f49d 100644 --- a/scripts/enqueue.ts +++ b/scripts/enqueue.ts @@ -4,6 +4,8 @@ const note_filter = Deno.args.length >= 3 ? Deno.args[2] : "" const ws = new WebSocket(Deno.args[0]) +const requeue = Deno.env.has("REQUEUE") + function run_enqueue() { let kind = "http" for (const line of file.split("\n")) { @@ -16,7 +18,7 @@ function run_enqueue() { if (note_filter.length && note != note_filter) continue const key = `${kind}:${id}`; ws.send(JSON.stringify({ t: "metadata", key, data: { output: name, title: name } })) - ws.send(JSON.stringify({ t: "enqueue", key })) + ws.send(JSON.stringify({ t: "enqueue", key, ignore_complete: requeue })) } } ws.send(JSON.stringify({ t: "save" })) |