Skip to content

Commit

Permalink
add single process property
Browse files Browse the repository at this point in the history
Signed-off-by: Carla Vieira <[email protected]>
  • Loading branch information
carlaprv committed Oct 5, 2022
1 parent 38de49d commit 83f784e
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions kedro/io/cached_dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,12 @@ class CachedDataSet(AbstractDataSet):
class as shown above.
"""

# this dataset cannot be used with ``ParallelRunner``,
# therefore it has the attribute ``_SINGLE_PROCESS = True``
# for parallelism within a Spark pipeline please consider
# ``ThreadRunner`` instead
_SINGLE_PROCESS = True

def __init__(
self,
dataset: Union[AbstractDataSet, Dict],
Expand Down

0 comments on commit 83f784e

Please sign in to comment.