Timeout for tcp messaging was hardcoded to 0.1, which empirically resulted in excessive worker terminations, drastically slowing processing.
Originally a "timeout" kwarg was included for Task() definition, but this information is not currently applied in the master branch code.
I found it more appropriate and parsimonious to include a "tcp_timeout" kwarg in the convenience.run_blockwise() call that initializes scheduling of tasks.
Timeout for tcp messaging was hardcoded to 0.1, which empirically resulted in excessive worker terminations, drastically slowing processing.
Originally a "timeout" kwarg was included for Task() definition, but this information is not currently applied in the master branch code.
I found it more appropriate and parsimonious to include a "tcp_timeout" kwarg in the convenience.run_blockwise() call that initializes scheduling of tasks.