Python
/
ruff
mirror of https://github.com/astral-sh/ruff
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ci: add `python/typeshed` to ecosystem check (#3559)

This commit is contained in:
Xuehai Pan 2023-03-17 02:19:48 +08:00 committed by GitHub
parent eff84442bc
commit e99e1fae2b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 36 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
scripts/check_ecosystem.py
View File

@ -29,6 +29,9 @@ class Repository(NamedTuple):
org: str org: str
repo: str repo: str
ref: str ref: str
select: str = "ALL"
ignore: str = ""
exclude: str = ""
@asynccontextmanager @asynccontextmanager
async def clone(self: Self) -> "AsyncIterator[Path]": async def clone(self: Self) -> "AsyncIterator[Path]":
@ -59,6 +62,7 @@ REPOSITORIES = {
"bokeh": Repository("bokeh", "bokeh", "branch-3.2"), "bokeh": Repository("bokeh", "bokeh", "branch-3.2"),
"scikit-build": Repository("scikit-build", "scikit-build", "main"), "scikit-build": Repository("scikit-build", "scikit-build", "main"),
"airflow": Repository("apache", "airflow", "main"), "airflow": Repository("apache", "airflow", "main"),
"typeshed": Repository("python", "typeshed", "main", select="PYI"),
} }
SUMMARY_LINE_RE = re.compile(r"^(Found \d+ error.*)|(.*potentially fixable with.*)$") SUMMARY_LINE_RE = re.compile(r"^(Found \d+ error.*)|(.*potentially fixable with.*)$")
@ -68,15 +72,23 @@ class RuffError(Exception):
"""An error reported by ruff.""" """An error reported by ruff."""
async def check(*, ruff: Path, path: Path) -> "Sequence[str]": async def check(
*,
ruff: Path,
path: Path,
select: str,
ignore: str = "",
exclude: str = "",
) -> "Sequence[str]":
"""Run the given ruff binary against the specified path.""" """Run the given ruff binary against the specified path."""
ruff_args = ["check", "--no-cache", "--exit-zero", "--select", select]
if ignore:
ruff_args.extend(["--ignore", ignore])
if exclude:
ruff_args.extend(["--exclude", exclude])
proc = await create_subprocess_exec( proc = await create_subprocess_exec(
ruff.absolute(), ruff.absolute(),
"check", *ruff_args,
"--no-cache",
"--exit-zero",
"--select",
"ALL",
".", ".",
stdout=PIPE, stdout=PIPE,
stderr=PIPE, stderr=PIPE,
@ -123,8 +135,24 @@ async def compare(ruff1: Path, ruff2: Path, repo: Repository) -> Diff | None:
async with repo.clone() as path: async with repo.clone() as path:
try: try:
async with asyncio.TaskGroup() as tg: async with asyncio.TaskGroup() as tg:
check1 = tg.create_task(check(ruff=ruff1, path=path)) check1 = tg.create_task(
check2 = tg.create_task(check(ruff=ruff2, path=path)) check(
ruff=ruff1,
path=path,
select=repo.select,
ignore=repo.ignore,
exclude=repo.exclude,
),
)
check2 = tg.create_task(
check(
ruff=ruff2,
path=path,
select=repo.select,
ignore=repo.ignore,
exclude=repo.exclude,
),
)
except ExceptionGroup as e: except ExceptionGroup as e:
raise e.exceptions[0] from e raise e.exceptions[0] from e