dask distributed issues

dask / distributed

A distributed task scheduler for Dask

https://distributed.dask.org

BSD 3-Clause "New" or "Revised" License

1.55k stars 711 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Bump release-drafter/release-drafter from 5 to 6

#8699 dependabot[bot] opened 15 hours ago
1
Package upload plugin

#8698 dbalabka opened 4 days ago
0
Add Prometheus metrics for cumulative task transition counts on workers

#8697 hendrikmakait opened 5 days ago
2
Add Prometheus metrics that tracks cumulative counts of handler calls

#8696 hendrikmakait opened 5 days ago
4
Worker plugin can not be registered on worker unless its entire package source uploaded on server

#8695 dbalabka opened 5 days ago
6
Broken WorkerPlugin can break entire cluster by freezing workers

#8694 Fogapod opened 5 days ago
1
Fix pynvml handles

#8693 quasiben opened 5 days ago
2
Log key collision count in `update_graph` log event

#8692 hendrikmakait closed 4 days ago
1
Fix `log_event` plugin hook with multiple topics

#8691 hendrikmakait closed 5 days ago
1
Better exception if scheduler disconnects from client

#8690 fjetter opened 6 days ago
1
More useful warning if a plugin type is provided instead of instance

#8689 fjetter opened 6 days ago
1
Improve structure of event logging

#8688 hendrikmakait opened 6 days ago
7
Avoid rounding error in `test_prometheus_collect_count_total_by_cost_multipliers`

#8687 hendrikmakait closed 4 days ago
1
Rename `safe` to `expected` in `Scheduler.remove_worker`.

#8686 hendrikmakait closed 6 days ago
1
PubSub functionality kills stream-based connections due to race conditions

#8685 hendrikmakait opened 1 week ago
4
split frames for large graphs

#8684 fjetter opened 1 week ago
1
Swallowing the `CommClosedError` when the stream handler closes may remove relevant exception information

#8683 hendrikmakait opened 1 week ago
0
Log the exception that caused us to close a stream handler

#8682 hendrikmakait closed 1 week ago
1
Eagerly update aggregate statistics for `TaskPrefix` instead of calculating them on-demand

#8681 hendrikmakait closed 1 week ago
1
Update aggregate statistics for `TaskPrefix` instead of calculating them on demand

#8680 hendrikmakait closed 1 week ago
0
P2P tasks log compute failures even if they are later restarted

#8679 hendrikmakait opened 1 week ago
0
Warn user if we encounter too many tasks groups on the scheduler

#8678 hendrikmakait opened 1 week ago
1
Disable `TaskProgress` dashboard component if there are too many task groups

#8677 hendrikmakait closed 1 week ago
2
P2P Rechunking - Graph submission time reduction - HLG Layer for P2P rechunking

#8676 fjetter opened 1 week ago
0
Track cluster growth during P2P operations

#8675 hendrikmakait opened 1 week ago
0
Restart P2P on `OSError: [Errno 28] No space left on device` instead of failing if the cluster has grown since we started

#8674 hendrikmakait opened 1 week ago
2
Restart P2P if cluster significantly grew in size

#8673 fjetter opened 1 week ago
3
Improve graph submission time for P2P rechunking by avoiding unpack recursion into indices

#8672 fjetter closed 1 week ago
3
Client.map() keys as a list breaks Dask queue system

#8671 arneyjfs opened 1 week ago
6
Iterate over copy of `Server.digests_total_since_heartbeat` to avoid `RuntimeError`

#8670 hendrikmakait closed 1 week ago
2
Update to `Server.digests_total_since_heartbeat` during heartbeat may kill worker

#8669 hendrikmakait closed 1 week ago
0
Log task state in "Compute Failed" message

#8668 hendrikmakait closed 1 week ago
1
Fix too strict assertion in shuffle code for pandas subclasses

#8667 jorisvandenbossche closed 2 weeks ago
2
Improved errors and reduced logging for P2P RPC calls

#8666 hendrikmakait closed 1 week ago
1
Change Safe to Expected Keyword in remove_worker

#8665 alex-rakowski closed 6 days ago
1
Reduce noise from erring tasks that are not supposed to be running

#8664 hendrikmakait closed 2 weeks ago
1
[P2P] Log event during failure

#8663 hendrikmakait closed 1 week ago
1
Adjust P2P tests for dask-expr

#8662 hendrikmakait closed 1 week ago
1
Add Prometheus gauge for task groups

#8661 hendrikmakait closed 1 week ago
2
[P2P] `merge_unpack` does not reschedule on `ShuffleClosedError`

#8660 hendrikmakait opened 2 weeks ago
0
[P2P] Be robust to timeouts during shuffle barrier

#8659 hendrikmakait opened 2 weeks ago
1
Deploying dask using Docker on different machines

#8658 simplew2011 closed 1 week ago
4
Partial P2P rechunks cause explosion in the task group count

#8656 hendrikmakait closed 2 weeks ago
0
Reduce task group count for partial P2P rechunks

#8655 hendrikmakait closed 2 weeks ago
5
Scatter with broadcast=True does not broadcast

#8657 gsakkis closed 4 days ago
2
Ability to specify cost value for computations

#8654 BitTheByte opened 3 weeks ago
1
Worker profile limited to a short timespan

#8653 RaphaelRobidas opened 3 weeks ago
0
Update gpuCI `RAPIDS_VER` to `24.08`

#8652 github-actions[bot] closed 2 weeks ago
1
Bump JamesIves/github-pages-deploy-action from 4.5.0 to 4.6.1

#8651 dependabot[bot] opened 4 weeks ago
1
DOC: fix indent in code example in Update task-launch.rst

#8650 raybellwaves closed 4 weeks ago
1