Sébastien
12/09/2020, 9:36 PM#> prefect auth login -t "<my token>"
Error attempting to communicate with Prefect Cloud
I can confirm that ~/.prefect/config.toml
isn't being created.
Trying to use python3 start.py
to register any flow gives:
prefect.utilities.exceptions.ClientError: Malformed response received from Cloud - please ensure that you have an API token properly configured.
which unfortunately doesn't add any info.
Pinging <http://api.prefect.io|api.prefect.io>
works:
PING <http://api.prefect.io|api.prefect.io> (34.96.72.220) 56(84) bytes of data.
64 bytes from <http://220.72.96.34.bc.googleusercontent.com|220.72.96.34.bc.googleusercontent.com> (34.96.72.220): icmp_seq=1 ttl=116 time=3.71 ms
Any ideas?josh
12/09/2020, 9:46 PMfrom prefect import Client
client = Client(api_token=<your_token>)
output = client.graphql(
query={"query": {"user": {"default_membership": "tenant_id"}}}
)
client.login_to_tenant( tenant_id=output.data.user[0].default_membership.tenant_id
)
Sébastien
12/09/2020, 9:48 PMprefect auth login -t X
while I was trying to use my RUNNER token from my other server's config.toml
josh
12/09/2020, 10:21 PMSébastien
12/09/2020, 10:22 PMexecutor=DaskExecutor(adapt_kwargs={"maximum": 10})
didn't help, still running the map on a single worker - taking exactly as much time.
Is there an easy way to add logs to check the executor?executor=DaskExecutor(cluster_kwargs={"n_workers": 10})
as well thinking it would be simpler. It runs, but same issue as before.debug = true
[logging]
level = "DEBUG"
and
executor=DaskExecutor(..., debug=True)
no debug logs to be found"processes": False, "threads_per_worker": 8
— exact same result.lscpu
just to make sure — no change.