@@ -368,6 +368,7 @@ def test_attr_wrapper(ts):
368
368
# get attribute
369
369
result = grouped .dtype
370
370
expected = grouped .agg (lambda x : x .dtype )
371
+ tm .assert_series_equal (result , expected )
371
372
372
373
# make sure raises error
373
374
msg = "'SeriesGroupBy' object has no attribute 'foo'"
@@ -1503,7 +1504,7 @@ def test_groupby_reindex_inside_function():
1503
1504
ind = date_range (start = "2012/1/1" , freq = "5min" , periods = periods )
1504
1505
df = DataFrame ({"high" : np .arange (periods ), "low" : np .arange (periods )}, index = ind )
1505
1506
1506
- def agg_before (hour , func , fix = False ):
1507
+ def agg_before (func , fix = False ):
1507
1508
"""
1508
1509
Run an aggregate func on the subset of data.
1509
1510
"""
@@ -1518,13 +1519,9 @@ def _func(data):
1518
1519
1519
1520
return _func
1520
1521
1521
- def afunc (data ):
1522
- d = data .select (lambda x : x .hour < 11 ).dropna ()
1523
- return np .max (d )
1524
-
1525
1522
grouped = df .groupby (lambda x : datetime (x .year , x .month , x .day ))
1526
- closure_bad = grouped .agg ({"high" : agg_before (11 , np .max )})
1527
- closure_good = grouped .agg ({"high" : agg_before (11 , np .max , True )})
1523
+ closure_bad = grouped .agg ({"high" : agg_before (np .max )})
1524
+ closure_good = grouped .agg ({"high" : agg_before (np .max , True )})
1528
1525
1529
1526
tm .assert_frame_equal (closure_bad , closure_good )
1530
1527
0 commit comments