[trivikr]

Replaces the two near-identical async.queue blocks in collect-commit-labels.js and find-matching-prs.js with a small forEachConcurrent helper, and removes the async dependency. The concurrency limit stays at 15.

Also drops a broken next() call in find-matching-prs.js. next was always undefined there, and the queue swallowed the resulting error, so results weren't affected.

[rvagg]

as long as you're making it fully async, make the callback (onFetch) go away, this just needs a try/catch around await cache[key]:

      try {
        const issue = await cache[key]
        if (issue.labels) {
          commit.labels = issue.labels.map((label) => label.name)
        }
      } catch (err) {
        console.error('Error fetching issue #%s: %s', commit.ghIssue, err.message)
      }

[trivikr]

Done in 4d62b27

The worker is now async and awaits cache[key] in a try/catch, and onFetch is gone.

One small behavior change: an error while reading labels (e.g. issue resolving to undefined) is now logged and skipped like a fetch error. On main it's an unhandled rejection that crashes the process.