diff --git a/scripts/podx-tools.sh b/scripts/podx-tools.sh index 0047641..b0b78e9 100755 --- a/scripts/podx-tools.sh +++ b/scripts/podx-tools.sh @@ -882,7 +882,7 @@ PY rq-clear-transcribe) : "${REDIS_URL:=redis://redis:6379/0}" 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 from redis import Redis from rq import Queue @@ -907,9 +907,8 @@ def clear(name): try: q.empty() except Exception: pass print(f"[rq] cleared queue '{name}' and registries.") -clear('transcribe') -PY - "$REDIS_URL" + clear('transcribe') + PY else echo "docker compose not found; cannot run rq inside container." >&2; exit 1 fi @@ -918,7 +917,7 @@ PY rq-clear-default) : "${REDIS_URL:=redis://redis:6379/0}" 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 from redis import Redis from rq import Queue @@ -943,9 +942,8 @@ def clear(name): try: q.empty() except Exception: pass print(f"[rq] cleared queue '{name}' and registries.") -clear('default') -PY - "$REDIS_URL" + clear('default') + PY else echo "docker compose not found; cannot run rq inside container." >&2; exit 1 fi @@ -954,7 +952,7 @@ PY rq-clear-all) : "${REDIS_URL:=redis://redis:6379/0}" 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 from redis import Redis from rq import Queue @@ -981,8 +979,7 @@ def clear(name): print(f"[rq] cleared queue '{name}' and registries.") for name in ('default','transcribe'): clear(name) -PY - "$REDIS_URL" + PY else echo "docker compose not found; cannot run rq inside container." >&2; exit 1 fi