fix(csv-import): fix incorrect map merge
This commit is contained in:
parent
823b367d5a
commit
0d283fd9e5
@ -934,8 +934,8 @@ dbTable PSValidator{..} dbtable@DBTable{ dbtIdent = dbtIdent'@(toPathPiece -> db
|
|||||||
= handle $ throwM . (DBCsvException (toNamedRecord inpCsv) :: Text -> DBCsvException k') <=< dbtCsvRenderException
|
= handle $ throwM . (DBCsvException (toNamedRecord inpCsv) :: Text -> DBCsvException k') <=< dbtCsvRenderException
|
||||||
| otherwise
|
| otherwise
|
||||||
= id
|
= id
|
||||||
in yieldM . doHandle . runConduit $ dbtCsvComputeActions x .| C.fold accActionMap Map.empty
|
in C.sourceList <=< lift . doHandle . runConduit $ dbtCsvComputeActions x .| C.foldMap pure
|
||||||
innerAct .| C.foldMap id
|
innerAct .| C.fold accActionMap Map.empty
|
||||||
actionMap <- flip evalStateT Map.empty . runConduit $ sourceDiff .| transPipe lift dbtCsvComputeActions'
|
actionMap <- flip evalStateT Map.empty . runConduit $ sourceDiff .| transPipe lift dbtCsvComputeActions'
|
||||||
|
|
||||||
when (Map.null actionMap) $ do
|
when (Map.null actionMap) $ do
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user