[Bug]: DataFrame`groupby` does not support named aggregation

[robmoore]

What happened?

Attempts to use a named aggregation in a groupby result in a TypeError (TypeError: DeferredGroupBy.agg() missing 1 required positional argument: 'fn').

Example case:

# Same error occurs when using explicit pd.NamedAggs instead of tuples
df.groupby(['quarter', 'program']).agg(total_spend=('revenue', 'sum'), avg_spend=('revenue', 'mean'))

Issue Priority

Priority: 3 (minor)

Issue Components

• Component: Python SDK
• Component: Java SDK
• Component: Go SDK
• Component: Typescript SDK
• Component: IO connector
• Component: Beam examples
• Component: Beam playground
• Component: Beam katas
• Component: Website
• Component: Spark Runner
• Component: Flink Runner
• Component: Samza Runner
• Component: Twister2 Runner
• Component: Hazelcast Jet Runner
• Component: Google Cloud Dataflow Runner

[tvalentyn]

Thanks for reporting, it should be possible to support this - would you be interested in taking a closer look and contributing a PR?

[SiddharthJadhav99]

@tvalentyn can you assign this issue to me? I'll be able to support this.

[tvalentyn]

hi @SiddharthJadhav99 just checking if you have any questions or need help.

[SiddharthJadhav99]

hey @tvalentyn & @robmoore, It would be really helpful if you could send a sample code which would replicate the error or if you could elaborate a little regarding this bug.

[robmoore]

@SiddharthJadhav99 Please see example in the pd.NamedAgg examples for Beam issue 27278 Colab notebook. The error is replicated in the section entitled "Example using Beam Interactive".

[SiddharthJadhav99]

hey @tvalentyn, i tried to solve this issue but I am unable to do so. You may unassign me from this issue. thanks @robmoore for your cooperation and help!