Skip to content

Commit 2b1630a

Browse files
committed
kafka: use const id for tracker insert (flip const trips hlint redundant-flip)
1 parent d3a6fcc commit 2b1630a

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/Pkg/Queue.hs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -566,7 +566,7 @@ decoupledLoop appLogger appCtx tp role batchSize clientId fn = do
566566
subChunks = subChunksFor role nowEpoch byTP
567567
for_ subChunks \work@(tpKey, _, _, offs, bytes) ->
568568
atomically do
569-
modifyTVar' trackerVar (Map.insertWith (flip const) tpKey (PartProgress (minimum offs) mempty))
569+
modifyTVar' trackerVar (Map.insertWith (const id) tpKey (PartProgress (minimum offs) mempty))
570570
modifyTVar' inflightVar (+ bytes)
571571
writeTBQueue workQ work
572572
-- DLQ backoff: records present but none due → avoid a 10Hz re-poll of

0 commit comments

Comments
 (0)