Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[REVIEW] Refactor nvtx annotations in cudf & dask-cudf #10396

Merged
merged 11 commits into from
Mar 9, 2022
198 changes: 92 additions & 106 deletions python/cudf/cudf/core/dataframe.py

Large diffs are not rendered by default.

209 changes: 100 additions & 109 deletions python/cudf/cudf/core/frame.py

Large diffs are not rendered by default.

5 changes: 2 additions & 3 deletions python/cudf/cudf/core/groupby/groupby.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@
from functools import cached_property

import numpy as np
from nvtx import annotate

import cudf
from cudf._lib import groupby as libgroupby
Expand All @@ -18,7 +17,7 @@
from cudf.core.column.column import arange, as_column
from cudf.core.mixins import Reducible, Scannable
from cudf.core.multiindex import MultiIndex
from cudf.utils.utils import GetAttrGetItemMixin
from cudf.utils.utils import GetAttrGetItemMixin, _cudf_nvtx_annotate


# The three functions below return the quantiles [25%, 50%, 75%]
Expand Down Expand Up @@ -207,7 +206,7 @@ def cumcount(self):
def _groupby(self):
return libgroupby.GroupBy(self.grouping.keys, dropna=self._dropna)

@annotate("GROUPBY_AGG", domain="cudf_python")
@_cudf_nvtx_annotate
def agg(self, func):
"""
Apply aggregation(s) to the groups.
Expand Down
Loading