Skip to content

Commit

Permalink
Update daft/dataframe/dataframe.py
Browse files Browse the repository at this point in the history
Co-authored-by: Desmond Cheong <[email protected]>
  • Loading branch information
jaychia and desmondcheongzx authored Jul 30, 2024
1 parent 0595c56 commit 0783b6e
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion daft/dataframe/dataframe.py
Original file line number Diff line number Diff line change
Expand Up @@ -234,7 +234,7 @@ def iter_partitions(
results_buffer_size: how many partitions to allow in the results buffer (defaults to 1).
Setting this value will buffer results up to the provided size and provide backpressure
to dataframe execution based on the rate of consumption from the returned iterator. Setting this to
`None` will result in a buffer of unbounded size, causing the dataframe run asynchronously
`None` will result in a buffer of unbounded size, causing the dataframe to run asynchronously
to completion.
"""
if results_buffer_size is not None and not results_buffer_size > 0:
Expand Down

0 comments on commit 0783b6e

Please sign in to comment.