Skip to content

[Data] Fixed min_scheduling_resources to fallback to incremental_resource_usage by default#60997

Merged
alexeykudinkin merged 2 commits into
masterfrom
ak/res-min-sch-fix
Feb 12, 2026
Merged

[Data] Fixed min_scheduling_resources to fallback to incremental_resource_usage by default#60997
alexeykudinkin merged 2 commits into
masterfrom
ak/res-min-sch-fix

Conversation

@alexeykudinkin

Copy link
Copy Markdown
Contributor

Description

  • Fixed min_scheduling_resources to fallback to incremental_resource_usage by default
  • Explicitly overridden for HashShufflingOperatorBase

Related issues

Link related issues: "Fixes #1234", "Closes #1234", or "Related to #1234".

Additional information

Optional: Add implementation details, API changes, usage examples, screenshots, etc.

…al_resources`

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
@alexeykudinkin alexeykudinkin requested a review from a team as a code owner February 12, 2026 01:33

@gemini-code-assist gemini-code-assist Bot left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

Code Review

This pull request updates the default behavior of min_scheduling_resources in PhysicalOperator to fall back to incremental_resource_usage(). This is a sensible default. However, the explicit override for HashShufflingOperatorBase is now redundant due to this change in the base class and can be removed to avoid code duplication.

Comment on lines +1050 to +1052
def min_scheduling_resources(self) -> ExecutionResources:
return self.incremental_resource_usage()

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

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

medium

This override of min_scheduling_resources is now redundant. The base class PhysicalOperator is also being updated in this pull request to return self.incremental_resource_usage(). This method can be removed from HashShufflingOperatorBase to avoid unnecessary code duplication.

@alexeykudinkin alexeykudinkin added the go add ONLY when ready to merge, run all tests label Feb 12, 2026
@alexeykudinkin alexeykudinkin enabled auto-merge (squash) February 12, 2026 02:10
@alexeykudinkin alexeykudinkin merged commit 9cbcdb4 into master Feb 12, 2026
6 of 7 checks passed
@alexeykudinkin alexeykudinkin deleted the ak/res-min-sch-fix branch February 12, 2026 02:20
alexeykudinkin added a commit that referenced this pull request Feb 12, 2026
…urce_usage by default (#60997)

## Description

- Fixed min_scheduling_resources to fallback to
incremental_resource_usage by default
 - Explicitly overridden for `HashShufflingOperatorBase`

## Related issues
> Link related issues: "Fixes #1234", "Closes #1234", or "Related to
#1234".

## Additional information
> Optional: Add implementation details, API changes, usage examples,
screenshots, etc.

---------

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
aslonnie pushed a commit that referenced this pull request Feb 12, 2026
…remental_resource_usage by default (#60998)

Cherry-pick of #60997

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
ayushk7102 pushed a commit to ayushk7102/ray that referenced this pull request Feb 12, 2026
…urce_usage by default (ray-project#60997)

## Description

- Fixed min_scheduling_resources to fallback to
incremental_resource_usage by default
 - Explicitly overridden for `HashShufflingOperatorBase`

## Related issues
> Link related issues: "Fixes ray-project#1234", "Closes ray-project#1234", or "Related to
ray-project#1234".

## Additional information
> Optional: Add implementation details, API changes, usage examples,
screenshots, etc.

---------

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
Signed-off-by: Ayush Kumar <ayush.kumar@anyscale.com>
ans9868 pushed a commit to ans9868/ray that referenced this pull request Feb 18, 2026
…urce_usage by default (ray-project#60997)

## Description

- Fixed min_scheduling_resources to fallback to
incremental_resource_usage by default
 - Explicitly overridden for `HashShufflingOperatorBase`

## Related issues
> Link related issues: "Fixes ray-project#1234", "Closes ray-project#1234", or "Related to
ray-project#1234".

## Additional information
> Optional: Add implementation details, API changes, usage examples,
screenshots, etc.

---------

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
Signed-off-by: Adel Nour <ans9868@nyu.edu>
Aydin-ab pushed a commit to kunling-anyscale/ray that referenced this pull request Feb 20, 2026
…urce_usage by default (ray-project#60997)

## Description

- Fixed min_scheduling_resources to fallback to
incremental_resource_usage by default
 - Explicitly overridden for `HashShufflingOperatorBase`

## Related issues
> Link related issues: "Fixes ray-project#1234", "Closes ray-project#1234", or "Related to
ray-project#1234".

## Additional information
> Optional: Add implementation details, API changes, usage examples,
screenshots, etc.

---------

Signed-off-by: Alexey Kudinkin <ak@anyscale.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

go add ONLY when ready to merge, run all tests

2 participants