Matt Alhonte
05/02/2022, 9:56 PMECSRun
would I put Dask security args? Like tls_ca_file
and stuff?Kevin Kho
05/02/2022, 10:03 PMfrom distributed import Client
from distributed.security import Security
sec = Security(tls_ca_file='cluster_ca.pem',
tls_client_cert='cli_cert.pem',
tls_client_key='cli_key.pem',
require_encryption=True)
client = Client(..., security=sec)
Matt Alhonte
05/02/2022, 10:04 PMworker_extra_args
and scheduler_extra_args
Kevin Kho
05/02/2022, 10:12 PMsec = Security(tls_ca_file='cluster_ca.pem',
tls_client_cert='cli_cert.pem',
tls_client_key='cli_key.pem',
require_encryption=True)
executor = DaskExecutor(
cluster_class="dask_cloudprovider.FargateCluster",
cluster_kwargs={
"image": "prefecthq/prefect:latest",
"n_workers": 5,
...
},
client_kwargs={"security":sec}
)
?Matt Alhonte
05/02/2022, 10:14 PMKevin Kho
05/02/2022, 11:58 PM