Skip to content

Commit 9185fba

Browse files
committed
replace itertools group_by with chunk_by
1 parent 0f335f4 commit 9185fba

File tree

1 file changed

+8
-8
lines changed
  • src/utils/consistency

1 file changed

+8
-8
lines changed

src/utils/consistency/db.rs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -15,21 +15,21 @@ pub(super) fn load(conn: &mut postgres::Client, config: &Config) -> Result<Crate
1515
releases.yanked
1616
FROM crates
1717
INNER JOIN releases ON releases.crate_id = crates.id
18-
UNION ALL
19-
-- crates & releases that are already queued
18+
UNION ALL
19+
-- crates & releases that are already queued
2020
-- don't have to be requeued.
2121
SELECT queue.name, queue.version, NULL as yanked
22-
FROM queue
23-
LEFT OUTER JOIN crates ON crates.name = queue.name
22+
FROM queue
23+
LEFT OUTER JOIN crates ON crates.name = queue.name
2424
LEFT OUTER JOIN releases ON (
25-
releases.crate_id = crates.id AND
25+
releases.crate_id = crates.id AND
2626
releases.version = queue.version
2727
)
2828
WHERE queue.attempt < $1 AND (
29-
crates.id IS NULL OR
29+
crates.id IS NULL OR
3030
releases.id IS NULL
3131
)
32-
) AS inp
32+
) AS inp
3333
ORDER BY name, version",
3434
iter::once(config.build_attempts as i32),
3535
)?;
@@ -41,7 +41,7 @@ pub(super) fn load(conn: &mut postgres::Client, config: &Config) -> Result<Crate
4141
// we can use Itertools.group_by on it.
4242
.iterator()
4343
.map(|row| row.expect("error fetching rows"))
44-
.group_by(|row| row.get("name"))
44+
.chunk_by(|row| row.get("name"))
4545
{
4646
let releases: Releases = release_rows
4747
.map(|row| Release {

0 commit comments

Comments
 (0)