fix test

Author: deep1401

api/test/api/test_experiment_service.py

@@ -23,7 +23,8 @@ async def mock_get_experiments_dir():
 
 
 @pytest.mark.asyncio
-async def test_experiment_create_and_get_real(_tmp_experiments_dir):
+async def test_experiment_create_and_get_real(tmp_experiments_dir):
+    _ = tmp_experiments_dir
     name = f"real_exp_{uuid.uuid4().hex[:8]}"
     cfg = {"description": "integration test experiment"}
     exp_id = await experiment_service.experiment_create(name, cfg)
@@ -39,14 +40,16 @@ async def test_experiment_create_and_get_real(_tmp_experiments_dir):
 
 
 @pytest.mark.asyncio
-async def test_missing_experiment_returns_none(_tmp_experiments_dir):
+async def test_missing_experiment_returns_none(tmp_experiments_dir):
+    _ = tmp_experiments_dir
     # experiment_get should return None for non-existent id (FileNotFoundError handled)
     assert await experiment_service.experiment_get("no_such_experiment") is None
 
 
 # Added test to hit the new FileNotFoundError except-clauses in experiment_service
 @pytest.mark.asyncio
-async def test_missing_experiment_operations_handle_FileNotFound(_tmp_experiments_dir):
+async def test_missing_experiment_operations_handle_FileNotFound(tmp_experiments_dir):
+    _ = tmp_experiments_dir
     """
     Call the service functions that now catch FileNotFoundError to ensure those
     branches are executed and no exceptions are raised.
@@ -60,7 +63,8 @@ async def test_missing_experiment_operations_handle_FileNotFound(_tmp_experiment
 
 
 @pytest.mark.asyncio
-async def test_update_and_delete_flow_real(_tmp_experiments_dir):
+async def test_update_and_delete_flow_real(tmp_experiments_dir):
+    _ = tmp_experiments_dir
     name = f"cycle_exp_{uuid.uuid4().hex[:8]}"
     await experiment_service.experiment_create(name, {"a": 1})
 

api/test/shared/test_worker_leader.py

@@ -41,7 +41,9 @@ def mock_lock_path(tmp_path, monkeypatch):
     return lock_file
 
 
-def test_try_acquire_leadership_success(_reset_worker_leader_state, _mock_lock_path):
+def test_try_acquire_leadership_success(reset_worker_leader_state, mock_lock_path):
+    _ = reset_worker_leader_state
+    _ = mock_lock_path
     """Test successful leadership acquisition."""
     import transformerlab.shared.worker_leader as wl
 
@@ -53,7 +55,9 @@ def test_try_acquire_leadership_success(_reset_worker_leader_state, _mock_lock_p
         mock_flock.assert_called_once()
 
 
-def test_try_acquire_leadership_already_leader(_reset_worker_leader_state, _mock_lock_path):
+def test_try_acquire_leadership_already_leader(reset_worker_leader_state, mock_lock_path):
+    _ = reset_worker_leader_state
+    _ = mock_lock_path
     """Test that acquiring leadership when already leader returns True immediately."""
     import transformerlab.shared.worker_leader as wl
 
@@ -67,7 +71,9 @@ def test_try_acquire_leadership_already_leader(_reset_worker_leader_state, _mock
         mock_flock.assert_not_called()
 
 
-def test_try_acquire_leadership_failure(_reset_worker_leader_state, _mock_lock_path):
+def test_try_acquire_leadership_failure(reset_worker_leader_state, mock_lock_path):
+    _ = reset_worker_leader_state
+    _ = mock_lock_path
     """Test that leadership acquisition fails when lock cannot be acquired."""
     import transformerlab.shared.worker_leader as wl
 
@@ -86,7 +92,9 @@ def test_try_acquire_leadership_failure(_reset_worker_leader_state, _mock_lock_p
             mock_file.close.assert_called_once()
 
 
-def test_lock_file_created_on_success(_reset_worker_leader_state, _mock_lock_path):
+def test_lock_file_created_on_success(reset_worker_leader_state, mock_lock_path):
+    _ = reset_worker_leader_state
+    _ = mock_lock_path
     """Test that lock file is created when leadership is acquired."""
     import transformerlab.shared.worker_leader as wl
 
@@ -105,14 +113,17 @@ def test_lock_file_created_on_success(_reset_worker_leader_state, _mock_lock_pat
             mock_file.flush.assert_called_once()
 
 
-def test_is_leader_initial_state(_reset_worker_leader_state):
+def test_is_leader_initial_state(reset_worker_leader_state):
+    _ = reset_worker_leader_state
     """Test that is_leader returns False initially."""
     import transformerlab.shared.worker_leader as wl
 
     assert wl.is_leader() is False
 
 
-def test_fcntl_unavailable_fallback(_reset_worker_leader_state, _mock_lock_path, caplog, monkeypatch):
+def test_fcntl_unavailable_fallback(reset_worker_leader_state, mock_lock_path, caplog, monkeypatch):
+    _ = reset_worker_leader_state
+    _ = mock_lock_path
     """Test fallback behavior when fcntl is unavailable (e.g., Windows)."""
     import transformerlab.shared.worker_leader as wl
     import logging