Kirill Suvorov
Kirill Suvorov
## What do these changes do? - [x] first commit message and PR title follow format outlined [here](https://modin.readthedocs.io/en/latest/development/contributing.html#commit-message-formatting) > **_NOTE:_** If you edit the PR title to match this format,...
## What do these changes do? - [x] first commit message and PR title follow format outlined [here](https://modin.readthedocs.io/en/latest/development/contributing.html#commit-message-formatting) > **_NOTE:_** If you edit the PR title to match this format,...
Apply approaches from [PR-7136](https://github.com/modin-project/modin/pull/7136) for TreeReduce and GroupByReduce operators ## What do these changes do? - [x] first commit message and PR title follow format outlined [here](https://modin.readthedocs.io/en/latest/development/contributing.html#commit-message-formatting) > **_NOTE:_** If...
## What do these changes do? - [ ] first commit message and PR title follow format outlined [here](https://unidist.readthedocs.io/en/latest/developer/contributing.html#commit-message-formatting) > **_NOTE:_** If you edit the PR title to match this...
Unidist returns a result, but one of the workers cannot finish the job. ```python import unidist import time @unidist.remote def g(number): time.sleep(1) return number**2 @unidist.remote def f(): results = []...
Reproducer: ```python import unidist import time @unidist.remote def sleep(seconds): time.sleep(seconds) @unidist.remote def f(arr): unidist.get(sleep.remote(0.2)) return sum(arr) def g(): obj_ref = unidist.put(100) arr = [obj_ref] for i in range(22): arr.append(f.remote(arr)) time.sleep(0.1)...
- [x] Is part of #7266 - [x] Tests added / passed - [x] Passes `pre-commit run --all-files` Hello, I'm Kirill from the Modin group. We've implemented conversion to and...
Dynamic partitioning works with different slowdowns for different functions, data and startup parameters (CPU count, MinPartitionSize and possibly others) This task was created based on the results of these PRs:...
## Details - Add support for StreamingStatus - Fix converting for GenerationConfig - Add some types ## Tickets - CVS-167755