Function process_node

src/ghstack/forensics.py:80–126

(n: Dict[str, Any])

    nodes = r["data"]["repository"]["pullRequest"]["commits"]["nodes"]

    async def process_node(n: Dict[str, Any]) -> str:
        commit = n["commit"]
        status = commit["status"]
        icon = "❔"
        text = ""
        buildid_text = ""
        if status is not None:
            contexts = status["contexts"]
        else:
            contexts = []
        for c in contexts:
            # TODO: Stop hard-coding me
            if c["context"] != "ci/circleci: pytorch_linux_xenial_py3_clang5_asan_test":
                continue
            m = RE_CIRCLECI_URL.match(c["targetUrl"])
            if not m:
                icon = "🍆"
                break
            if c["state"] == "SUCCESS":
                icon = "✅"
                break
            buildid = m.group(1)
            buildid_text = " ({})".format(buildid)
            r = await circleci.get(
                "project/github/{name}/{owner}/{buildid}".format(
                    buildid=buildid, **params
                )
            )
            if not r["failed"]:
                # It was just cancelled (don't check "cancelled"; that's
                # true even if the job failed otherwise; it just means
                # workflow got cancelled)
                icon = "❔"
                break
            icon = "❌"
            async with aiohttp.request(
                "get", r["steps"][-1]["actions"][-1]["output_url"]
            ) as resp:
                log_json = await resp.json()
                buf = []
                for e in log_json:
                    buf.append(e["message"])
                text = "\n" + strip_sccache("\n".join(buf))
                text = text[-1500:]
        return "{} {} {}{}{}".format(
            icon, commit["oid"][:8], commit["messageHeadline"], buildid_text, text
        )

    for n in nodes:
        print(await process_node(n))