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 Mar 5, 2025
1 parent 7343892 commit de302dd
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion coffea/processor/executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -622,6 +622,7 @@ def __call__(
accumulator: Accumulatable,
):
from .taskvine_executor import run

return (
run(
self,
Expand Down Expand Up @@ -1994,7 +1995,9 @@ def run(
processor_instance=pi_to_send,
)

if self.format == "root" and isinstance(self.executor, (TaskVineExecutor, WorkQueueExecutor)):
if self.format == "root" and isinstance(
self.executor, (TaskVineExecutor, WorkQueueExecutor)
):
# keep chunks in generator, use a copy to count number of events
# this is cheap, as we are reading from the cache
chunks_to_count = self.preprocess(fileset, treename)
Expand Down

0 comments on commit de302dd

Please sign in to comment.