fix(ruff): resolve all remaining linting errors

- CLI: Add explicit re-exports for config, ssh, and get_pod_ssh_ip_port (F401)
- Pod commands: Replace bare except with specific OSError handling (E722)
- FastAPI: Remove duplicate Job import from worker_state (F811)
- RPC Job: Use isinstance() instead of type() for dict comparison (E721)
- Llama2 template: Add ruff noqa directive for template placeholder code (F821)
- Download tests: Rename duplicate test_download_file to test_download_file_with_content_disposition (F811)

All ruff checks now pass without errors.

Author: deanq

runpod/cli/__init__.py

@@ -2,7 +2,7 @@
 
 import threading
 
-from .groups import config, ssh
+from .groups import config as config, ssh as ssh
 
 STOP_EVENT = threading.Event()
 

runpod/cli/groups/pod/commands.py

@@ -242,5 +242,5 @@ def sync_pods(source_pod_id, dest_pod_id, source_workspace, dest_workspace):
         try:
             if 'local_temp_path' in locals():
                 os.unlink(local_temp_path)
-        except:
+        except OSError:
             pass

runpod/cli/groups/project/starter_templates/llama2/src/handler.py

@@ -1,6 +1,7 @@
 """ A template for a Llama2 handler file. """
 
 # pylint: skip-file
+# ruff: noqa
 
 
 from transformers import HfApi

runpod/cli/groups/ssh/__init__.py

@@ -1,3 +1,3 @@
 """ CLI functions for SSH. """
 
-from . import functions
+from . import functions as functions

runpod/cli/utils/__init__.py

@@ -1,3 +1,3 @@
 """ Collection of utility functions for the CLI """
 
-from .rp_info import get_pod_ssh_ip_port
+from .rp_info import get_pod_ssh_ip_port as get_pod_ssh_ip_port

runpod/serverless/modules/rp_fastapi.py

@@ -17,7 +17,7 @@
 from .rp_handler import is_generator
 from .rp_job import run_job, run_job_generator
 from .rp_ping import Heartbeat
-from .worker_state import Job, JobsProgress
+from .worker_state import JobsProgress
 
 RUNPOD_ENDPOINT_ID = os.environ.get("RUNPOD_ENDPOINT_ID", None)
 

runpod/serverless/modules/rp_job.py

@@ -127,7 +127,7 @@ async def handle_job(session: ClientSession, config: Dict[str, Any], job) -> dic
         async for stream_output in generator_output:
             log.debug(f"Stream output: {stream_output}", job["id"])
 
-            if type(stream_output.get("output")) == dict:
+            if isinstance(stream_output.get("output"), dict):
                 if stream_output["output"].get("error"):
                     stream_output = {"error": str(stream_output["output"]["error"])}
 

tests/test_serverless/test_utils/test_download.py

@@ -175,7 +175,7 @@ def test_download_file(self, mock_file, mock_get):
 
     @patch("runpod.serverless.utils.rp_download.SyncClientSession.get")
     @patch("builtins.open", new_callable=mock_open)
-    def test_download_file(self, mock_file, mock_get):
+    def test_download_file_with_content_disposition(self, mock_file, mock_get):
         """
         Tests download_file using filename from Content-Disposition
         """