diff options
| -rw-r--r-- | python/process_queue.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/process_queue.py b/python/process_queue.py index bff34cb7..5e072696 100644 --- a/python/process_queue.py +++ b/python/process_queue.py @@ -47,7 +47,7 @@ def get_trades(q, queue_name='bond_trades'): df = pd.DataFrame([loads(e) for e in r]) list_trades = [] if not df.empty: - for tradeid, v in df.sort('lastupdate').groupby('id'): + for tradeid, v in df.sort_values(by='lastupdate').groupby('id'): trade = aux(v) if trade is not None: list_trades.append(trade) |