Aleksandr Liadov
01/04/2023, 4:31 PMmy_flow.with_options(
task_runner=DaskTaskRunner(
address="<tls://10.4.83.2:8786>"
)
Log:
prefect.task_runner.dask - Connecting to an existing Dask cluster at <tls://10.4.83.2:8786>
17:20:30.497 | ERROR | Flow run 'jolly-griffin' - Crash detected! Execution was interrupted by an unexpected exception: TypeError: TLS expects a `ssl_context` argument of type ssl.SSLContext (perhaps check your TLS configuration?) Instead got None
What do I wrong?
Dask cluster running on Kubernetes managed with Dask Gateway.Mason Menges
01/04/2023, 7:16 PMAleksandr Liadov
01/05/2023, 8:17 AMtask_runner=DaskTaskRunner(
address=cluster_dask.scheduler_info["address"],
client_kwargs={"security": cluster_dask.security},
)