0

I'm a newbie to dask gateway, trying to learn how to use it.

I am just trying to open a dataframe and compute it. Something like:

auth = BasicAuth(username="my_user", password="my_password")
gateway = Gateway("http://my_path", auth=auth)
options = gateway.cluster_options()

cluster = gateway.new_cluster(cluster_options=options)
cluster.adapt(minimum=2, maximum=10)
client = cluster.get_client()

df_sample = dd.read_sql_query(...)
df_sample.compute()

The code works normally without dask gateway.

And I get an error like this (sorry, I can't copy-paste the code):

enter image description here

How can I fix this?

Rafael Higa
  • 655
  • 1
  • 8
  • 17
  • How did you start the gateway server? It looks like a serialization problem between the dask cluster and your client. – Guillaume EB Jan 28 '23 at 06:35

0 Answers0