Skip to content

Commit d6fbeca

Browse files
committed
Prevent threaded Dask workers in DistRDF backend
1 parent 84e7794 commit d6fbeca

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
@@ -112,10 +112,10 @@ def __init__(self, daskclient: Optional[Client] = None):
112112
threads = worker.get("nthreads", 1)
113113

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

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

0 commit comments

Comments
 (0)