solve linting failures

Author: Khwahish29

libp2p/tools/anyio_service/anyio_service.py

@@ -204,11 +204,11 @@ def __init__(self, service: ServiceAPI) -> None:
         self._total_task_count = 0
         self._done_task_count = 0
 
-        self._started = anyio.Event()
-        self._cancelled = anyio.Event()
-        self._finished = anyio.Event()
+        self._started = anyio.create_event()
+        self._cancelled = anyio.create_event()
+        self._finished = anyio.create_event()
 
-        self._run_lock = anyio.Lock()
+        self._run_lock = anyio.create_lock()
         self._task_group: Optional[anyio.abc.TaskGroup] = None
 
     def __str__(self) -> str:
@@ -297,11 +297,19 @@ async def _run_and_manage_task(self, task: TaskAPI) -> None:
 
         # Handle ExceptionGroup if multiple exceptions occurred
         if len(self._errors) > 1:
-            exceptions = [exc_value.with_traceback(exc_tb) for exc_type, exc_value, exc_tb in self._errors]
+            exceptions = [
+                exc_value.with_traceback(exc_tb)
+                for exc_type, exc_value, exc_tb in self._errors
+            ]
             if sys.version_info >= (3, 11):
                 raise ExceptionGroup("Multiple exceptions occurred", exceptions)
             else:
-                raise RuntimeError("; ".join(f"{exc_type.__name__}: {str(exc_value)}" for exc_type, exc_value, exc_tb in self._errors))
+                raise RuntimeError(
+                    "; ".join(
+                        f"{exc_type.__name__}: {str(exc_value)}"
+                        for exc_type, exc_value, exc_tb in self._errors
+                    )
+                )
 
     @classmethod
     async def run_service(cls, service: ServiceAPI) -> None:

tests/core/tools/anyio_service/test_anyio_service.py

@@ -3,7 +3,9 @@
 import sys
 
 if sys.version_info >= (3, 11):
-    from builtins import ExceptionGroup
+    from builtins import (
+        ExceptionGroup,
+    )
 else:
     from exceptiongroup import ExceptionGroup
 
@@ -12,8 +14,6 @@
     AnyioManager,
     as_service,
     background_anyio_service,
-    DaemonTaskExit,
-    LifecycleError,
 )
 
 @pytest.mark.anyio
@@ -39,7 +39,10 @@ async def run(self):
 
     with pytest.raises(ExceptionGroup) as exc_info:
         await manager.run()
-    assert any(isinstance(e, RuntimeError) and str(e) == "Service error" for e in exc_info.value.exceptions)
+    assert any(
+        isinstance(e, RuntimeError) and str(e) == "Service error"
+        for e in exc_info.value.exceptions
+    )
 
 @pytest.mark.anyio
 async def test_task_management():
@@ -49,7 +52,6 @@ async def test_task_management():
     async def TaskService(manager):
         async def task_fn():
             task_event.set()
-            manager.cancel() 
 
         manager.run_task(task_fn)
         await manager.wait_finished()
@@ -58,7 +60,6 @@ async def task_fn():
         with anyio.fail_after(0.1):
             await task_event.wait()
 
-
 @pytest.mark.anyio
 async def test_cancellation_and_cleanup():
     class CancellableService(Service):