Enforce formatter checks and apply repository-wide formatting

Co-authored-by: Shri Sukhani <shrisukhani@users.noreply.github.com>

Author: cursoragent

.github/workflows/ci.yml

@@ -37,6 +37,9 @@ jobs:
       - name: Lint
         run: python -m ruff check .
 
+      - name: Formatting
+        run: python -m ruff format --check .
+
       - name: Compile sources
         run: python -m compileall -q hyperbrowser examples tests
 

Makefile

@@ -1,15 +1,21 @@
-.PHONY: install lint test build check
+.PHONY: install lint format-check format test build check
 
 install:
 	python -m pip install -e . pytest ruff build
 
 lint:
 	python -m ruff check .
 
+format-check:
+	python -m ruff format --check .
+
+format:
+	python -m ruff format .
+
 test:
 	python -m pytest -q
 
 build:
 	python -m build
 
-check: lint test build
+check: lint format-check test build

README.md

@@ -167,6 +167,7 @@ except HyperbrowserTimeoutError:
 ```bash
 pip install -e . pytest ruff build
 python -m ruff check .
+python -m ruff format --check .
 python -m pytest -q
 python -m build
 ```

examples/sync_scrape.py

@@ -29,7 +29,9 @@ def main() -> None:
         if result.data and result.data.markdown:
             print(result.data.markdown[:500])
         else:
-            print(f"Scrape finished with status={result.status} and no markdown payload.")
+            print(
+                f"Scrape finished with status={result.status} and no markdown payload."
+            )
 
 
 if __name__ == "__main__":

hyperbrowser/__init__.py

@@ -1,7 +1,11 @@
 from .client.sync import Hyperbrowser
 from .client.async_client import AsyncHyperbrowser
 from .config import ClientConfig
-from .exceptions import HyperbrowserError, HyperbrowserPollingError, HyperbrowserTimeoutError
+from .exceptions import (
+    HyperbrowserError,
+    HyperbrowserPollingError,
+    HyperbrowserTimeoutError,
+)
 from .version import __version__
 
 __all__ = [

hyperbrowser/client/managers/async_manager/agents/browser_use.py

@@ -65,8 +65,9 @@ async def start_and_wait(
         return await wait_for_job_result_async(
             operation_name=f"browser-use task job {job_id}",
             get_status=lambda: self.get_status(job_id).status,
-            is_terminal_status=lambda status: status
-            in {"completed", "failed", "stopped"},
+            is_terminal_status=lambda status: (
+                status in {"completed", "failed", "stopped"}
+            ),
             fetch_result=lambda: self.get(job_id),
             poll_interval_seconds=poll_interval_seconds,
             max_wait_seconds=max_wait_seconds,

hyperbrowser/client/managers/async_manager/agents/claude_computer_use.py

@@ -59,8 +59,9 @@ async def start_and_wait(
         return await wait_for_job_result_async(
             operation_name=f"Claude Computer Use task job {job_id}",
             get_status=lambda: self.get_status(job_id).status,
-            is_terminal_status=lambda status: status
-            in {"completed", "failed", "stopped"},
+            is_terminal_status=lambda status: (
+                status in {"completed", "failed", "stopped"}
+            ),
             fetch_result=lambda: self.get(job_id),
             poll_interval_seconds=poll_interval_seconds,
             max_wait_seconds=max_wait_seconds,

hyperbrowser/client/managers/async_manager/agents/cua.py

@@ -57,8 +57,9 @@ async def start_and_wait(
         return await wait_for_job_result_async(
             operation_name=f"CUA task job {job_id}",
             get_status=lambda: self.get_status(job_id).status,
-            is_terminal_status=lambda status: status
-            in {"completed", "failed", "stopped"},
+            is_terminal_status=lambda status: (
+                status in {"completed", "failed", "stopped"}
+            ),
             fetch_result=lambda: self.get(job_id),
             poll_interval_seconds=poll_interval_seconds,
             max_wait_seconds=max_wait_seconds,

hyperbrowser/client/managers/async_manager/agents/gemini_computer_use.py

@@ -59,8 +59,9 @@ async def start_and_wait(
         return await wait_for_job_result_async(
             operation_name=f"Gemini Computer Use task job {job_id}",
             get_status=lambda: self.get_status(job_id).status,
-            is_terminal_status=lambda status: status
-            in {"completed", "failed", "stopped"},
+            is_terminal_status=lambda status: (
+                status in {"completed", "failed", "stopped"}
+            ),
             fetch_result=lambda: self.get(job_id),
             poll_interval_seconds=poll_interval_seconds,
             max_wait_seconds=max_wait_seconds,

hyperbrowser/client/managers/async_manager/agents/hyper_agent.py

@@ -59,8 +59,9 @@ async def start_and_wait(
         return await wait_for_job_result_async(
             operation_name=f"HyperAgent task {job_id}",
             get_status=lambda: self.get_status(job_id).status,
-            is_terminal_status=lambda status: status
-            in {"completed", "failed", "stopped"},
+            is_terminal_status=lambda status: (
+                status in {"completed", "failed", "stopped"}
+            ),
             fetch_result=lambda: self.get(job_id),
             poll_interval_seconds=poll_interval_seconds,
             max_wait_seconds=max_wait_seconds,