Skip to content

Add node affinity for reducer and merger

Codecov / codecov/patch failed Sep 29, 2024 in 0s

24.76% of diff hit (target 78.71%)

View this Pull Request on Codecov

24.76% of diff hit (target 78.71%)

Annotations

Check warning on line 126 in daft/context.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/context.py#L126

Added line #L126 was not covered by tests

Check warning on line 128 in daft/context.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/context.py#L128

Added line #L128 was not covered by tests

Check warning on line 60 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L60

Added line #L60 was not covered by tests

Check warning on line 62 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L62

Added line #L62 was not covered by tests

Check warning on line 1622 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1622

Added line #L1622 was not covered by tests

Check warning on line 1635 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1625-L1635

Added lines #L1625 - L1635 were not covered by tests

Check warning on line 1637 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1637

Added line #L1637 was not covered by tests

Check warning on line 1641 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1640-L1641

Added lines #L1640 - L1641 were not covered by tests

Check warning on line 1643 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1643

Added line #L1643 was not covered by tests

Check warning on line 1646 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1646

Added line #L1646 was not covered by tests

Check warning on line 1649 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1648-L1649

Added lines #L1648 - L1649 were not covered by tests

Check warning on line 1654 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1654

Added line #L1654 was not covered by tests

Check warning on line 1660 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1660

Added line #L1660 was not covered by tests

Check warning on line 1673 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1663-L1673

Added lines #L1663 - L1673 were not covered by tests

Check warning on line 1675 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1675

Added line #L1675 was not covered by tests

Check warning on line 1679 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1678-L1679

Added lines #L1678 - L1679 were not covered by tests

Check warning on line 1686 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1682-L1686

Added lines #L1682 - L1686 were not covered by tests

Check warning on line 1702 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1701-L1702

Added lines #L1701 - L1702 were not covered by tests

Check warning on line 1706 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1705-L1706

Added lines #L1705 - L1706 were not covered by tests

Check warning on line 1714 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1709-L1714

Added lines #L1709 - L1714 were not covered by tests

Check warning on line 1717 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1716-L1717

Added lines #L1716 - L1717 were not covered by tests

Check warning on line 1724 in daft/execution/physical_plan.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan.py#L1724

Added line #L1724 was not covered by tests

Check warning on line 16 in daft/execution/physical_plan_shuffles.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan_shuffles.py#L15-L16

Added lines #L15 - L16 were not covered by tests

Check warning on line 20 in daft/execution/physical_plan_shuffles.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan_shuffles.py#L19-L20

Added lines #L19 - L20 were not covered by tests

Check warning on line 41 in daft/execution/physical_plan_shuffles.py

See this annotation in the file changed.

@codecov codecov / codecov/patch

daft/execution/physical_plan_shuffles.py#L40-L41

Added lines #L40 - L41 were not covered by tests