Use ruff for linting (#742)

Signed-off-by: Casper Beyer <[email protected]>

Author: caspervonb

.github/workflows/check.yml

@@ -1,4 +1,4 @@
-name: Check
+name: check
 on:
     push:
         branches:
@@ -27,3 +27,24 @@ jobs:
 
             - name: Run format check
               run: uv run ruff format --check
+
+    lint:
+        runs-on: ubuntu-latest
+        name: lint
+        steps:
+            - name: Check out repository
+              uses: actions/checkout@v5
+
+            - name: Set up Python
+              uses: actions/setup-python@v6
+              with:
+                  python-version: "3.8"
+
+            - name: Install uv
+              uses: astral-sh/setup-uv@v6
+
+            - name: Install the project
+              run: uv sync --dev
+
+            - name: Run lint check
+              run: uv run ruff check

nats-server/src/nats/server/__init__.py

@@ -24,7 +24,6 @@
 import os
 import re
 import socket
-import tempfile
 from typing import Self
 
 # Set up logging

nats/examples/advanced.py

@@ -1,8 +1,9 @@
 import asyncio
 
-import nats
 from nats.errors import NoServersError, TimeoutError
 
+import nats
+
 
 async def main():
     async def disconnected_cb():

nats/examples/basic.py

@@ -1,9 +1,10 @@
 import asyncio
 
-import nats
 from common import args
 from nats.errors import TimeoutError
 
+import nats
+
 
 async def main():
     arguments, _ = args.get_args("Run a basic example.")
@@ -33,7 +34,7 @@ async def message_handler(msg):
         async for msg in sub.messages:
             print(f"Received a message on '{msg.subject} {msg.reply}': {msg.data.decode()}")
             await sub.unsubscribe()
-    except Exception as e:
+    except Exception:
         pass
 
     async def help_request(msg):

nats/examples/clustered.py

@@ -1,9 +1,10 @@
 import asyncio
 from datetime import datetime
 
-import nats
 from nats.aio.errors import ErrConnectionClosed, ErrNoServers, ErrTimeout
 
+import nats
+
 
 async def run():
     # Setup pool of servers from a NATS cluster.
@@ -66,7 +67,7 @@ async def subscribe_handler(msg):
             try:
                 await nc.publish(f"help.{i}", b"A")
                 await nc.flush(0.500)
-            except ErrConnectionClosed as e:
+            except ErrConnectionClosed:
                 print("Connection closed prematurely.")
                 break
             except ErrTimeout as e:

nats/examples/connect.py

@@ -1,8 +1,9 @@
 import asyncio
 
-import nats
 from common import args
 
+import nats
+
 
 async def main():
     async def disconnected_cb():

nats/examples/context-manager.py

@@ -1,8 +1,9 @@
 import asyncio
 
-import nats
 from common import args
 
+import nats
+
 
 async def main():
     is_done = asyncio.Future()

nats/examples/jetstream.py

@@ -1,8 +1,9 @@
 import asyncio
 
-import nats
 from nats.errors import TimeoutError
 
+import nats
+
 
 async def main():
     nc = await nats.connect("localhost")

nats/examples/micro/service.py

@@ -2,9 +2,10 @@
 import contextlib
 import signal
 
-import nats
 import nats.micro
 
+import nats
+
 
 async def echo(req) -> None:
     """Echo the request data back to the client."""

nats/examples/publish.py

@@ -1,8 +1,9 @@
 import asyncio
 
-import nats
 from common import args
 
+import nats
+
 
 async def main():
     arguments, _ = args.get_args("Run a publish example.", "Usage: python examples/publish.py")