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

Data: PandasBlockAccessor does not have the attribute _munge_conflict #46275

Open
denadai2 opened this issue Jun 26, 2024 · 0 comments
Open

Data: PandasBlockAccessor does not have the attribute _munge_conflict #46275

denadai2 opened this issue Jun 26, 2024 · 0 comments
Labels
bug Something that is supposed to be working; but isn't triage Needs triage (eg: priority, bug/not-bug, and owning component)

Comments

@denadai2
Copy link

What happened + What you expected to happen

PandasBlockAccessor does not have the attribute _munge_conflict

  File "/home/ray/.local/lib/python3.10/site-packages/whatif/metrics/evaluator.py", line 187, in get_metrics
    _df = data.aggregate(*[m.agg_fn() for m in self.flat_metrics])
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/dataset.py", line 2000, in aggregate
    ret = self.groupby(None).aggregate(*aggs).take(1)
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/dataset.py", line 2460, in take
    for row in limited_ds.iter_rows():
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/iterator.py", line 245, in _wrapped_iterator
    for batch in batch_iterable:
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/iterator.py", line 162, in _create_iterator
    block_iterator, stats, blocks_owned_by_consumer = self._to_block_iterator()
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/_internal/iterator/iterator_impl.py", line 33, in _to_block_iterator
    block_iterator, stats, executor = ds._plan.execute_to_iterator()
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/exceptions.py", line 86, in handle_trace
    raise e.with_traceback(None) from SystemException()
ray.exceptions.RayTaskError(AttributeError): ray::map() (pid=250386, ip=10.169.90.67)
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/_internal/planner/exchange/aggregate_task_spec.py", line 57, in map
    parts = [BlockAccessor.for_block(p).combine(key, aggs) for p in partitions]
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/_internal/planner/exchange/aggregate_task_spec.py", line 57, in <listcomp>
    parts = [BlockAccessor.for_block(p).combine(key, aggs) for p in partitions]
  File "/home/ray/.local/lib/python3.10/site-packages/ray/data/_internal/pandas_block.py", line 492, in combine
    name = self._munge_conflict(name, count[name])
AttributeError: 'PandasBlockAccessor' object has no attribute '_munge_conflict'

name = PandasBlockAccessor._munge_conflict(

Versions / Dependencies

latest version of ray

Reproduction script

No needed to reproduce as it is a lacking method

Issue Severity

Medium: It is a significant difficulty but I can work around it.

@denadai2 denadai2 added bug Something that is supposed to be working; but isn't triage Needs triage (eg: priority, bug/not-bug, and owning component) labels Jun 26, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something that is supposed to be working; but isn't triage Needs triage (eg: priority, bug/not-bug, and owning component)
Projects
None yet
Development

No branches or pull requests

1 participant