Skip to content
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

Add default logs method to Spec Cluster #2889

Merged
merged 11 commits into from Jul 26, 2019

Conversation

mrocklin
Copy link
Member

Builds off of #2875

cc @jacobtomlinson

A dictionary of logs, with one item for the scheduler and one for
each worker
"""
return self.sync(self._logs, workers=workers, nanny=nanny)
Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

cc @jacobtomlinson you may want to briefly skim through this, just to get a sense of how the combination async/sync API stuff tends to work within dask-distributed today.

@mrocklin
Copy link
Member Author

Also @jcrist are you comfortable with this API for dask-yarn?

Copy link
Member

@jcrist jcrist left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Overall this seems fine. What about getting the scheduler logs, for implementations with a remote scheduler?

A list of worker addresses to select.
Defaults to all workers
nanny: bool, optional
Get the logs from the nannies rather than the workers
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

For implementations that grab logs from the backing system (e.g. kubernetes) this option may not make any sense - the only logs will be stdout/stderr of the process tree (IIRC the nanny and the worker share stdout/stderr). I'd be tempted to remove this option entirely.

Copy link
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Done

@mrocklin
Copy link
Member Author

Overall this seems fine. What about getting the scheduler logs, for implementations with a remote scheduler?

Currently the scheduler is included in these logs. It's the first entry with the name "Scheduler" (see notebook link above for an example)"

@jcrist
Copy link
Member

jcrist commented Jul 26, 2019

Perhaps there should be a scheduler=True kwarg (default True) to indicate whether to get the scheduler logs? So calling logs() will get everything, but you can avoid getting the scheduler logs if desired (say you wanted to ask for only a specific worker).

@mrocklin
Copy link
Member Author

Perhaps there should be a scheduler=True kwarg (default True) to indicate whether to get the scheduler logs? So calling logs() will get everything, but you can avoid getting the scheduler logs if desired (say you wanted to ask for only a specific worker).

Sure. Done. The tests that were just added might be a nice way to check this

@mrocklin
Copy link
Member Author

Thanks for the engagement Jim!

@mrocklin mrocklin merged commit 3e50887 into dask:master Jul 26, 2019
@mrocklin mrocklin deleted the default-logs-method branch July 26, 2019 21:24
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

3 participants