(is_local)
| 706 | client_is_local = True |
| 707 | |
| 708 | def _dask_client_close(is_local): |
| 709 | # We don't want to close an externally provided client |
| 710 | if is_local: |
| 711 | logger.info("Closing the local Dask client ...") |
| 712 | dask_client.close() |
| 713 | |
| 714 | print("The following files are scheduled for processing:") |
| 715 | for fln in flist: |