dask / dask/distributed

Add retries to RPC

Open
#4,969 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Python
Stars
1.7k
Forks
778
Avg merge
2h 50m
Merged PRs (30d)
3

Description

Currently we use `retry_operation` many times in our codebase like the following:

```python
await retry_operation(self.rpc(address=ws.address).gather, *args, **kwargs)
```

This is common enough that maybe we want to add it as a special keyword to `rpc` and the connection pool?

```python
await self.rpc(address=ws.address).gather(*args, **kwargs, retry=True)
```

This would conflict with using `retry=` as a parameter in any method. Maybe that's ok.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.