Skip to content

Commit

Permalink
[pre-commit.ci] auto fixes from pre-commit.com hooks
Browse files Browse the repository at this point in the history
for more information, see https://pre-commit.ci
  • Loading branch information
pre-commit-ci[bot] committed Jun 10, 2024
1 parent 7bb3509 commit 91a217e
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion pangeo_forge_recipes/transforms.py
Original file line number Diff line number Diff line change
Expand Up @@ -264,7 +264,8 @@ def expand(self, pcoll):

return (
pcoll
| "Assign keys via hash" >> beam.Map(lambda element: self.assign_keys(element, self.max_executors))
| "Assign keys via hash"
>> beam.Map(lambda element: self.assign_keys(element, self.max_executors))
| "Group per-executor work" >> beam.GroupByKey()
| "Unkey after grouping" >> beam.Values()
| "Limited concurrency file transfer"
Expand Down

0 comments on commit 91a217e

Please sign in to comment.