@delayed
def do_something():
# Does some work
pass
futures = [do_something() for x in range(100)]
compute(*futures)
does the default number of workers depend on our cpu cores? or does it run all the 100 in parallel (i assume this is not the case)
but how does it make a default worker count?
According to the dask website it defaults, as you suggest, to the number of cores.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With