Skip to content

Commit ec5e56a

Browse files
committed
Prevent threaded Dask workers in DistRDF backend
1 parent d307601 commit ec5e56a

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

  • bindings/distrdf/python/DistRDF/Backends/Dask

bindings/distrdf/python/DistRDF/Backends/Dask/Backend.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -111,10 +111,10 @@ def __init__(self, daskclient: Optional[Client] = None):
111111
threads = worker.get("nthreads", 1)
112112

113113
if threads > 1:
114-
raise RuntimeError(
115-
"DistRDF with Dask does not support threaded workers. "
116-
"Please use processes=True and threads_per_worker=1."
117-
)
114+
raise RuntimeError(
115+
"DistRDF with Dask does not support threaded workers. "
116+
"Please use processes=True and threads_per_worker=1."
117+
)
118118

119119
def optimize_npartitions(self) -> int:
120120
"""

0 commit comments

Comments
 (0)