devops: separated linting into own job

.github/workflows/ci.yml

@@ -5,6 +5,26 @@ on:
   pull_request:
     branches: [ master ]
 jobs:
+  infra:
+    name: Lint
+    runs-on: ubuntu-latest
+    steps:
+    - uses: actions/checkout@v2
+    - uses: microsoft/playwright-github-action@v1
+    - name: Set up Python
+      uses: actions/setup-python@v2
+      with:
+        python-version: 3.8
+    - name: Install dependencies
+      run: |
+        python -m pip install --upgrade pip
+        pip install -r local-requirements.txt
+        pip install .
+    - name: Lint
+      run: |
+        black --check .
+        mypy .
+        flake8 playwright tests
   build:
     timeout-minutes: 30
     strategy:
@@ -40,16 +60,17 @@ jobs:
         python -m pip install --upgrade pip
         pip install -r local-requirements.txt
         pip install .
-    - name: Lint
-      run: |
-        black --check .
-        mypy .
-        flake8  playwright tests
     - name: Build driver
       run: python build_driver.py
       env:
         PKG_CACHE_PATH: ${{ steps.node-pkg-cache.outputs.dir }}
     - name: Build package
       run: python build_package.py
     - name: Test
+      if: ${{ matrix.os == 'windows-latest' }}
+      # pytest-xdist does not exit on Windows
+      # https://github.com/pytest-dev/pytest-xdist/issues/60
       run: pytest -vv --browser=${{ matrix.browser }}
+    - name: Test
+      if: ${{ matrix.os != 'windows-latest' }}
+      run: pytest -vv --browser=${{ matrix.browser }} -n auto

client.py

@@ -17,7 +17,7 @@
 from playwright import browser_types
 
 
-async def run():
+async def run() -> None:
     print("Launching browser...")
     browser = await browser_types["webkit"].launch(headless=False)
     print("Contexts in browser: %d" % len(browser.contexts))
@@ -59,6 +59,7 @@ async def run():
 
     print("\nQuerying body...")
     body1 = await page1.querySelector("body")
+    assert body1
     print("Body text %s" % await body1.textContent())
 
     print("Closing page1...")

playwright/browser.py

@@ -20,9 +20,9 @@
 from types import SimpleNamespace
 from typing import Dict, List, Union
 
-if sys.version_info >= (3, 8):
+if sys.version_info >= (3, 8):  # pragma: no cover
     from typing import Literal
-else:
+else:  # pragma: no cover
     from typing_extensions import Literal
 
 

playwright/browser_context.py

@@ -34,7 +34,7 @@
 from types import SimpleNamespace
 from typing import Any, Callable, Dict, List, Optional, Union, TYPE_CHECKING
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.browser import Browser
 
 
@@ -189,7 +189,7 @@ async def waitForEvent(
             self, self._timeout_settings, event, predicate=predicate, timeout=timeout
         )
 
-    def _on_close(self):
+    def _on_close(self) -> None:
         if self._browser:
             self._browser._contexts.remove(self)
 

playwright/connection.py

@@ -32,13 +32,14 @@ async def send(self, method: str, params: dict = None) -> Any:
             params = dict()
         return await self._scope.send_message_to_server(self._guid, method, params)
 
-    def _on_message(self, method: str, params: Dict):
-        self.emit(method, params)
-
 
 class ChannelOwner(BaseEventEmitter):
     def __init__(
-        self, scope: "ConnectionScope", guid: str, initializer: Dict, is_scope=False
+        self,
+        scope: "ConnectionScope",
+        guid: str,
+        initializer: Dict,
+        is_scope: bool = False,
     ) -> None:
         super().__init__()
         self._guid = guid
@@ -64,7 +65,7 @@ def create_child(self, guid: str) -> "ConnectionScope":
         self._children.append(scope)
         return scope
 
-    def dispose(self):
+    def dispose(self) -> None:
         # Take care of hierarchy.
         for child in self._children:
             child.dispose()
@@ -98,7 +99,7 @@ def create_remote_object(self, type: str, guid: str, initializer: Dict) -> Any:
 
 
 class ProtocolCallback:
-    def __init__(self, loop: asyncio.AbstractEventLoop):
+    def __init__(self, loop: asyncio.AbstractEventLoop) -> None:
         self.stack_trace = "".join(traceback.format_stack()[-10:])
         self.future = loop.create_future()
 
@@ -145,7 +146,7 @@ async def _send_message_to_server(
         self._callbacks[id] = callback
         return await callback.future
 
-    def _dispatch(self, msg: ParsedMessagePayload):
+    def _dispatch(self, msg: ParsedMessagePayload) -> None:
 
         id = msg.get("id")
         if id:

playwright/console_message.py

@@ -33,20 +33,10 @@ def type(self) -> str:
     def text(self) -> str:
         return self._initializer["text"]
 
-    @property
-    def defaultValue(self) -> str:
-        return self._initializer["defaultValue"]
-
     @property
     def args(self) -> List[JSHandle]:
         return list(map(from_channel, self._initializer["args"]))
 
     @property
     def location(self) -> ConsoleMessageLocation:
         return self._initializer["location"]
-
-    async def accept(self, prompt_text: str = None) -> None:
-        await self._channel.send("accept", dict(promptText=prompt_text))
-
-    async def dismiss(self) -> None:
-        await self._channel.send("dismiss")

playwright/element_handle.py

@@ -37,12 +37,12 @@
     cast,
 )
 
-if sys.version_info >= (3, 8):
+if sys.version_info >= (3, 8):  # pragma: no cover
     from typing import Literal
-else:
+else:  # pragma: no cover
     from typing_extensions import Literal
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.frame import Frame
 
 

playwright/file_chooser.py

@@ -16,7 +16,7 @@
 
 from typing import List, Union, TYPE_CHECKING
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.page import Page
     from playwright.element_handle import ElementHandle
 

playwright/frame.py

@@ -38,12 +38,12 @@
 from playwright.serializers import normalize_file_payloads
 from typing import Any, Awaitable, Dict, List, Optional, Union, TYPE_CHECKING, cast
 
-if sys.version_info >= (3, 8):
+if sys.version_info >= (3, 8):  # pragma: no cover
     from typing import Literal
-else:
+else:  # pragma: no cover
     from typing_extensions import Literal
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.page import Page
 
 

playwright/helper.py

@@ -16,6 +16,7 @@
 import fnmatch
 import re
 import traceback
+from types import TracebackType
 
 from typing import (
     Any,
@@ -31,13 +32,13 @@
 
 import sys
 
-if sys.version_info >= (3, 8):
+if sys.version_info >= (3, 8):  # pragma: no cover
     from typing import Literal, TypedDict
-else:
+else:  # pragma: no cover
     from typing_extensions import Literal, TypedDict
 
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.network import Route, Request
 
 Cookie = List[Dict[str, Union[str, int, bool]]]
@@ -98,7 +99,7 @@ class ParsedMessagePayload(TypedDict, total=False):
 
 
 class URLMatcher:
-    def __init__(self, match: URLMatch):
+    def __init__(self, match: URLMatch) -> None:
         self._callback: Optional[Callable[[str], bool]] = None
         self._regex_obj: Optional[Pattern] = None
         if isinstance(match, str):
@@ -124,7 +125,7 @@ def __init__(self, parent: Optional["TimeoutSettings"]) -> None:
         self._timeout = 30000
         self._navigation_timeout = 30000
 
-    def set_timeout(self, timeout: int):
+    def set_timeout(self, timeout: int) -> None:
         self._timeout = timeout
 
     def timeout(self) -> int:
@@ -134,7 +135,7 @@ def timeout(self) -> int:
             return self._parent.timeout()
         return 30000
 
-    def set_navigation_timeout(self, navigation_timeout: int):
+    def set_navigation_timeout(self, navigation_timeout: int) -> None:
         self._navigation_timeout = navigation_timeout
 
     def navigation_timeout(self) -> int:
@@ -155,7 +156,7 @@ class TimeoutError(Error):
     pass
 
 
-def serialize_error(ex: Exception, tb) -> ErrorPayload:
+def serialize_error(ex: Exception, tb: Optional[TracebackType]) -> ErrorPayload:
     return dict(message=str(ex), stack="".join(traceback.format_tb(tb)))
 
 
@@ -193,7 +194,7 @@ def __init__(
         self.future = future
         self.timeout_future = timeout_future
 
-    def reject(self, is_crash: bool, target: str):
+    def reject(self, is_crash: bool, target: str) -> None:
         self.timeout_future.cancel()
         if self.event == "close" and not is_crash:
             return

playwright/js_handle.py

@@ -19,7 +19,7 @@
 from playwright.helper import Error, is_function_body
 from typing import Any, Dict, List, Optional, TYPE_CHECKING
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.element_handle import ElementHandle
 
 
@@ -88,7 +88,7 @@ async def jsonValue(self) -> Any:
         return parse_result(await self._channel.send("jsonValue"))
 
 
-def is_primitive_value(value: Any):
+def is_primitive_value(value: Any) -> bool:
     return (
         isinstance(value, bool)
         or isinstance(value, int)

playwright/main.py

@@ -27,7 +27,7 @@
 playwright_object: Playwright
 
 
-async def async_init():
+async def async_init() -> None:
     global playwright_object
     package_path = os.path.dirname(os.path.abspath(__file__))
     platform = sys.platform
@@ -61,6 +61,8 @@ async def async_init():
         stderr=asyncio.subprocess.PIPE,
         limit=32768,
     )
+    assert proc.stdout
+    assert proc.stdin
     connection = Connection(
         proc.stdout, proc.stdin, create_remote_object, asyncio.get_event_loop()
     )

playwright/network.py

@@ -23,7 +23,7 @@
 from playwright.helper import Error, ContinueParameters
 from typing import Any, Dict, List, Optional, Union, TYPE_CHECKING, cast
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.frame import Frame
 
 
@@ -104,7 +104,7 @@ async def fulfill(
             response["body"] = body
             response["isBase64"] = False
         elif isinstance(body, bytes):
-            response["body"] = base64.b64encode(body)
+            response["body"] = base64.b64encode(body).decode()
             response["isBase64"] = True
         await self._channel.send("fulfill", response)
 

playwright/page.py

@@ -53,12 +53,12 @@
 from types import SimpleNamespace
 from typing import Any, Awaitable, Callable, Dict, List, Union, TYPE_CHECKING, cast
 
-if sys.version_info >= (3, 8):
+if sys.version_info >= (3, 8):  # pragma: no cover
     from typing import Literal
-else:
+else:  # pragma: no cover
     from typing_extensions import Literal
 
-if TYPE_CHECKING:
+if TYPE_CHECKING:  # pragma: no cover
     from playwright.browser_context import BrowserContext
 
 
@@ -719,7 +719,7 @@ async def wait_for_event(
 
     future = target._scope._loop.create_future()
 
-    def listener(e: Any = None):
+    def listener(e: Any = None) -> None:
         if not predicate or predicate(e):
             future.set_result(e)
 

playwright/transport.py

@@ -49,7 +49,7 @@ async def _run(self) -> None:
                 msg = buffer.decode("utf-8")
                 obj = json.loads(msg)
 
-                if "DEBUGP" in os.environ:
+                if "DEBUGP" in os.environ:  # pragma: no cover
                     print("\x1b[33mRECV>\x1b[0m", json.dumps(obj, indent=2))
                 self.on_message(obj)
             except asyncio.IncompleteReadError:
@@ -58,7 +58,7 @@ async def _run(self) -> None:
 
     def send(self, message: Dict) -> None:
         msg = json.dumps(message)
-        if "DEBUGP" in os.environ:
+        if "DEBUGP" in os.environ:  # pragma: no cover
             print("\x1b[32mSEND>\x1b[0m", json.dumps(message, indent=2))
         data = bytes(msg, "utf-8")
         self._output.write(len(data).to_bytes(4, byteorder="little", signed=False))

setup.cfg

@@ -6,6 +6,15 @@ markers =
     only_platform
 [mypy]
 ignore_missing_imports = True
+python_version = 3.7
+warn_unused_ignores = False
+warn_redundant_casts = True
+warn_unused_configs = True
+check_untyped_defs = True
+disallow_untyped_defs = True
+[mypy-tests.*]
+check_untyped_defs = False
+disallow_untyped_defs = False
 [flake8]
 ignore =
     E501