-
-
Notifications
You must be signed in to change notification settings - Fork 1.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Astropy Units with Dask distributed #11317
Comments
@AlecThomson , since your example is reportedly not actually giving you the error you are reporting, can you at least share the full traceback? Thanks! |
Also helpful would be the astropy version. It could be related to race conditions in defining units, which we only recently solved... If possible, do try with latest master. |
@pllim in the output logs, it only prints the Error I put above, and not the full traceback. Although, I also just found that this (pretty dumb) change 'fixes' the issue is effectively:
@mhvk that sounds like the kind of issue I was worried about. Is that available via conda? Or, will I need to install from the git repo? Thanks! |
Hi @AlecThomson - you can install the latest development version either by cloning the repo and installing locally, e.g.:
Or you can try installing with pip from github directly:
|
Thanks @adrn. I just tested with astropy As a clarification, my worker function is actually more like
And raises error
The error in my original post occurs with something like:
But the underlying issue still seems to be the same, I think |
Sounds fishy. Did you try print out what |
Description
Hi there, I'm using dask to scale some work I'm doing. A small step includes some astropy unit conversions. This works fine when using
distributed.LocalCluster
for tests, but I'm getting some unexpected errors when I scale to usedask_jobqueue.SLURMCluster
. I'm not sure if the issue lies inside of Dask or astropy units, but I wanted to see if there was something I was missing, or some edge-case that might be cropping up.Expected behavior
I'm adding/converting arcseconds and degrees, which should convert.
Actual behavior
I get the following error when deployed on the Slurm cluster:
Steps to Reproduce
This is the closest to a basic version of the script I've been using. Frustratingly, though, this demo hasn't been reproducing the same error for me.
System Details
The text was updated successfully, but these errors were encountered: