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

feat(helm): add initial Dask support #701

Merged
merged 1 commit into from
Oct 31, 2024

Conversation

Alputer
Copy link
Member

@Alputer Alputer commented Sep 13, 2024

This pull request contains the ongoing work of dask integration into REANA.

@Alputer Alputer self-assigned this Sep 13, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 13, 2024
Copy link

codecov bot commented Sep 13, 2024

Codecov Report

Attention: Patch coverage is 65.78947% with 13 lines in your changes missing coverage. Please review.

Project coverage is 60.06%. Comparing base (70e8ad9) to head (15d0b97).
Report is 1 commits behind head on master.

Files with missing lines Patch % Lines
reana_server/validation.py 46.66% 8 Missing ⚠️
reana_server/rest/info.py 58.33% 5 Missing ⚠️
Additional details and impacted files

Impacted file tree graph

@@            Coverage Diff             @@
##           master     #701      +/-   ##
==========================================
+ Coverage   60.01%   60.06%   +0.05%     
==========================================
  Files          32       32              
  Lines        3509     3546      +37     
==========================================
+ Hits         2106     2130      +24     
- Misses       1403     1416      +13     
Files with missing lines Coverage Δ
reana_server/config.py 83.97% <100.00%> (+0.93%) ⬆️
reana_server/rest/workflows.py 51.13% <100.00%> (+0.09%) ⬆️
reana_server/rest/info.py 77.08% <58.33%> (-6.25%) ⬇️
reana_server/validation.py 70.73% <46.66%> (-5.74%) ⬇️

Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 13, 2024
@Alputer Alputer changed the title feat(dask): integrate Dask into reana (#701) feat(dask): Dask integration (#701) Sep 15, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 15, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 15, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 16, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 16, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 16, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 17, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 19, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 20, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 20, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 20, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 25, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 25, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Sep 25, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 24, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 24, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 24, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 24, 2024
@Alputer Alputer force-pushed the dask-integration branch 3 times, most recently from 376363e to 3b7f99b Compare October 24, 2024 11:57
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 24, 2024
Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 30, 2024
REANA_DASK_CLUSTER_MAX_MEMORY_LIMIT
):
raise REANAValidationError(
f'The "memory" requested in the dask resources exceeds the limit ({REANA_DASK_CLUSTER_MAX_MEMORY_LIMIT}).\nDecrease the number of workers requested or amount of memory consumed by a single worker.'
Copy link
Member

Choose a reason for hiding this comment

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

The limit testing seems to work nicely, I have tested a few scenarios.

value=REANA_DASK_CLUSTER_MAX_MEMORY_LIMIT,
)
cluster_information["dask_cluster_default_single_worker_memory"] = dict(
title="Memory for one Dask worker by default",
Copy link
Member

Choose a reason for hiding this comment

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

For the documentation strings (titles), please see the comments to the reana and reana-commons repositories.

Alputer added a commit to Alputer/reana-server that referenced this pull request Oct 30, 2024
@Alputer Alputer changed the title feat(dask): Dask integration (#701) feat(helm): add initial Dask support Oct 31, 2024
Copy link
Member

@tiborsimko tiborsimko left a comment

Choose a reason for hiding this comment

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

Works nicely 👍

@tiborsimko tiborsimko merged commit 15d0b97 into reanahub:master Oct 31, 2024
14 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
Status: Done
Development

Successfully merging this pull request may close these issues.

2 participants