fix ruff errors

Author: luke-beamcloud

fastloop/task.py

@@ -2,6 +2,7 @@
 import traceback
 import uuid
 from collections.abc import Callable
+from contextlib import suppress
 from datetime import datetime
 from typing import TYPE_CHECKING, Any
 
@@ -150,10 +151,8 @@ async def stop(self, task_id: str) -> bool:
         if not task:
             return False
         task.cancel()
-        try:
+        with suppress(asyncio.CancelledError, TimeoutError):
             await asyncio.wait_for(task, timeout=CANCEL_GRACE_PERIOD_S)
-        except (asyncio.CancelledError, TimeoutError):
-            pass
         return True
 
     async def stop_all(self) -> None:

fastloop/workflow.py

@@ -59,10 +59,10 @@ async def on_error(
 
     async def plan(
         self,
-        ctx: "LoopContext",
-        blocks: list["WorkflowBlock"],
-        current_block: "WorkflowBlock",
-        block_output: Any,
+        _ctx: "LoopContext",
+        _blocks: list["WorkflowBlock"],
+        _current_block: "WorkflowBlock",
+        _block_output: Any,
     ) -> BlockPlan | dict | None:
         """Override to control block execution order and scheduling.
 

tests/test_tasks.py

@@ -9,6 +9,7 @@
 import pytest
 
 from fastloop import ExecutorType, FastLoop, RetryPolicy, TaskStatus
+from fastloop.exceptions import LoopAlreadyDefinedError
 from fastloop.executor import run_in_executor, shutdown_executors
 from fastloop.models import TaskState
 from fastloop.scheduler import Schedule, validate_cron
@@ -280,7 +281,7 @@ def test_duplicate_task_raises(self):
         async def task1() -> str:
             return "1"
 
-        with pytest.raises(Exception):
+        with pytest.raises(LoopAlreadyDefinedError):
 
             @app.task(name="dup")
             async def task2() -> str: