Tooling update
This commit is contained in:
@@ -882,7 +882,7 @@ PY
|
|||||||
rq-clear-transcribe)
|
rq-clear-transcribe)
|
||||||
: "${REDIS_URL:=redis://redis:6379/0}"
|
: "${REDIS_URL:=redis://redis:6379/0}"
|
||||||
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
||||||
docker compose exec -T podx-worker-transcribe python - <<'PY'
|
docker compose exec -T podx-worker-transcribe python - "$REDIS_URL" <<'PY'
|
||||||
import sys
|
import sys
|
||||||
from redis import Redis
|
from redis import Redis
|
||||||
from rq import Queue
|
from rq import Queue
|
||||||
@@ -907,9 +907,8 @@ def clear(name):
|
|||||||
try: q.empty()
|
try: q.empty()
|
||||||
except Exception: pass
|
except Exception: pass
|
||||||
print(f"[rq] cleared queue '{name}' and registries.")
|
print(f"[rq] cleared queue '{name}' and registries.")
|
||||||
clear('transcribe')
|
clear('transcribe')
|
||||||
PY
|
PY
|
||||||
"$REDIS_URL"
|
|
||||||
else
|
else
|
||||||
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
||||||
fi
|
fi
|
||||||
@@ -918,7 +917,7 @@ PY
|
|||||||
rq-clear-default)
|
rq-clear-default)
|
||||||
: "${REDIS_URL:=redis://redis:6379/0}"
|
: "${REDIS_URL:=redis://redis:6379/0}"
|
||||||
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
||||||
docker compose exec -T podx-worker python - <<'PY'
|
docker compose exec -T podx-worker python - "$REDIS_URL" <<'PY'
|
||||||
import sys
|
import sys
|
||||||
from redis import Redis
|
from redis import Redis
|
||||||
from rq import Queue
|
from rq import Queue
|
||||||
@@ -943,9 +942,8 @@ def clear(name):
|
|||||||
try: q.empty()
|
try: q.empty()
|
||||||
except Exception: pass
|
except Exception: pass
|
||||||
print(f"[rq] cleared queue '{name}' and registries.")
|
print(f"[rq] cleared queue '{name}' and registries.")
|
||||||
clear('default')
|
clear('default')
|
||||||
PY
|
PY
|
||||||
"$REDIS_URL"
|
|
||||||
else
|
else
|
||||||
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
||||||
fi
|
fi
|
||||||
@@ -954,7 +952,7 @@ PY
|
|||||||
rq-clear-all)
|
rq-clear-all)
|
||||||
: "${REDIS_URL:=redis://redis:6379/0}"
|
: "${REDIS_URL:=redis://redis:6379/0}"
|
||||||
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
if command -v docker >/dev/null 2>&1 && command -v docker compose >/dev/null 2>&1; then
|
||||||
docker compose exec -T podx-worker-transcribe python - <<'PY'
|
docker compose exec -T podx-worker-transcribe python - "$REDIS_URL" <<'PY'
|
||||||
import sys
|
import sys
|
||||||
from redis import Redis
|
from redis import Redis
|
||||||
from rq import Queue
|
from rq import Queue
|
||||||
@@ -981,8 +979,7 @@ def clear(name):
|
|||||||
print(f"[rq] cleared queue '{name}' and registries.")
|
print(f"[rq] cleared queue '{name}' and registries.")
|
||||||
for name in ('default','transcribe'):
|
for name in ('default','transcribe'):
|
||||||
clear(name)
|
clear(name)
|
||||||
PY
|
PY
|
||||||
"$REDIS_URL"
|
|
||||||
else
|
else
|
||||||
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
echo "docker compose not found; cannot run rq inside container." >&2; exit 1
|
||||||
fi
|
fi
|
||||||
|
Reference in New Issue
Block a user