Fix coroutine .strip() bug — wrap await in parentheses

await self._ssh_exec(...).strip() calls .strip() on the coroutine,
not the result. Fixed all 11 occurrences to (await ...).strip().

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

src/content_engine/services/runpod_trainer.py

@@ -383,12 +383,12 @@ class RunPodTrainer:
                 install_cmds = []
 
                 # Check if already present in workspace
-                tuner_exist = await self._ssh_exec(ssh, f"test -f {tuner_dir}/pyproject.toml && echo EXISTS || echo MISSING").strip()
+                tuner_exist = (await self._ssh_exec(ssh, f"test -f {tuner_dir}/pyproject.toml && echo EXISTS || echo MISSING")).strip()
                 if tuner_exist == "EXISTS":
                     job._log("musubi-tuner found in workspace")
                 else:
                     # Check volume cache
-                    vol_exist = await self._ssh_exec(ssh, "test -f /runpod-volume/musubi-tuner/pyproject.toml && echo EXISTS || echo MISSING").strip()
+                    vol_exist = (await self._ssh_exec(ssh, "test -f /runpod-volume/musubi-tuner/pyproject.toml && echo EXISTS || echo MISSING")).strip()
                     if vol_exist == "EXISTS":
                         job._log("Restoring musubi-tuner from volume cache...")
                         await self._ssh_exec(ssh, f"rm -rf {tuner_dir} 2>/dev/null; cp -r /runpod-volume/musubi-tuner {tuner_dir}")
@@ -408,7 +408,7 @@ class RunPodTrainer:
                 ])
             else:
                 # SD 1.5 / SDXL / FLUX.1 use sd-scripts
-                scripts_exist = await self._ssh_exec(ssh, "test -f /workspace/sd-scripts/setup.py && echo EXISTS || echo MISSING").strip()
+                scripts_exist = (await self._ssh_exec(ssh, "test -f /workspace/sd-scripts/setup.py && echo EXISTS || echo MISSING")).strip()
                 if scripts_exist == "EXISTS":
                     job._log("Kohya sd-scripts already cached on volume, updating...")
                     install_cmds = [
@@ -443,9 +443,9 @@ class RunPodTrainer:
                 vae_path = f"{flux2_dir}/ae.safetensors"  # Original BFL format (not diffusers)
                 te_path = f"{flux2_dir}/text_encoder/model-00001-of-00010.safetensors"
 
-                dit_exists = await self._ssh_exec(ssh, f"test -f {dit_path} && echo EXISTS || echo MISSING").strip()
-                vae_exists = await self._ssh_exec(ssh, f"test -f {vae_path} && echo EXISTS || echo MISSING").strip()
-                te_exists = await self._ssh_exec(ssh, f"test -f {te_path} && echo EXISTS || echo MISSING").strip()
+                dit_exists = (await self._ssh_exec(ssh, f"test -f {dit_path} && echo EXISTS || echo MISSING")).strip()
+                vae_exists = (await self._ssh_exec(ssh, f"test -f {vae_path} && echo EXISTS || echo MISSING")).strip()
+                te_exists = (await self._ssh_exec(ssh, f"test -f {te_path} && echo EXISTS || echo MISSING")).strip()
 
                 if dit_exists != "EXISTS" or te_exists != "EXISTS":
                     missing = []
@@ -465,7 +465,7 @@ hf_hub_download('black-forest-labs/FLUX.2-dev', 'ae.safetensors', local_dir='{fl
 print('Downloaded ae.safetensors')
 " 2>&1 | tail -5""", timeout=600)
                     # Verify download
-                    vae_check = await self._ssh_exec(ssh, f"test -f {vae_path} && echo EXISTS || echo MISSING").strip()
+                    vae_check = (await self._ssh_exec(ssh, f"test -f {vae_path} && echo EXISTS || echo MISSING")).strip()
                     if vae_check != "EXISTS":
                         raise RuntimeError("Failed to download ae.safetensors")
                     job._log("VAE downloaded")
@@ -474,7 +474,7 @@ print('Downloaded ae.safetensors')
 
             else:
                 # SD 1.5 / SDXL / FLUX.1 — download single model file
-                model_exists = await self._ssh_exec(ssh, f"test -f /workspace/models/{hf_filename} && echo EXISTS || echo MISSING").strip()
+                model_exists = (await self._ssh_exec(ssh, f"test -f /workspace/models/{hf_filename} && echo EXISTS || echo MISSING")).strip()
                 if model_exists == "EXISTS":
                     job._log(f"Base model already cached on volume: {model_name}")
                 else:
@@ -488,7 +488,7 @@ hf_hub_download('{hf_repo}', '{hf_filename}', local_dir='/workspace/models')
 
                 # For FLUX.1, download additional required models (CLIP, T5, VAE)
                 if model_type == "flux":
-                    flux_files_check = await self._ssh_exec(ssh, "test -f /workspace/models/clip_l.safetensors && test -f /workspace/models/t5xxl_fp16.safetensors && test -f /workspace/models/ae.safetensors && echo EXISTS || echo MISSING").strip()
+                    flux_files_check = (await self._ssh_exec(ssh, "test -f /workspace/models/clip_l.safetensors && test -f /workspace/models/t5xxl_fp16.safetensors && test -f /workspace/models/ae.safetensors && echo EXISTS || echo MISSING")).strip()
                     if flux_files_check == "EXISTS":
                         job._log("FLUX.1 auxiliary models already cached on volume")
                     else:
@@ -652,9 +652,9 @@ resolution = [{resolution}, {resolution}]
             await self._ssh_exec(ssh, "mkdir -p /runpod-volume/loras")
             remote_output = f"/workspace/output/{name}.safetensors"
             # Find the output file
-            check = await self._ssh_exec(ssh, f"test -f {remote_output} && echo EXISTS || echo MISSING").strip()
+            check = (await self._ssh_exec(ssh, f"test -f {remote_output} && echo EXISTS || echo MISSING")).strip()
             if check == "MISSING":
-                remote_files = await self._ssh_exec(ssh, "ls /workspace/output/*.safetensors 2>/dev/null").strip()
+                remote_files = (await self._ssh_exec(ssh, "ls /workspace/output/*.safetensors 2>/dev/null")).strip()
                 if remote_files:
                     remote_output = remote_files.split("\n")[-1].strip()
                 else: