RGBCube/nu_scripts
1
Fork 0
mirror of https://github.com/RGBCube/nu_scripts synced 2025-08-01 06:37:46 +00:00
Code Issues Activity

fix(aggregate): propagate errors from aggregate operation closures (#1005)

Browse source
This commit is contained in:
Bahex 2024-12-31 22:58:40 +03:00 • committed by GitHub
parent 8db6af6376
commit c1bbcafb14
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

10
stdlib-candidate/std-rfc/aggregate/mod.nu
View file

@ -96,9 +96,17 @@ export def main [
let column_results = $columns let column_results = $columns
| each {|col| # col: cell-path | each {|col| # col: cell-path
let column = $group.items | get-item-with-error $col {span: $md.span, items: $grouped} let column = $group.items | get-item-with-error $col {span: $md.span, items: $grouped}
$agg_ops | items {|op_name, op| # op_name: string, op: closure let agg_results = $agg_ops | items {|op_name, op| # op_name: string, op: closure
$column | do $op | wrap (aggregate-col-name $col $op_name) $column | do $op | wrap (aggregate-col-name $col $op_name)
} }
for r in $agg_results {
if ($r | describe) == error {
return $r
}
}
$agg_results
| reduce {|it| merge $it} | reduce {|it| merge $it}
} }