From c4b253cc8858b13f9401496efeea2c62f38be86f Mon Sep 17 00:00:00 2001 From: "Bobby (aider)" Date: Thu, 13 Feb 2025 10:29:33 -0800 Subject: [PATCH] feat: Add debug logging to open trades functions --- src/trading/journal.py | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/src/trading/journal.py b/src/trading/journal.py index 7ce5315..d922c3f 100644 --- a/src/trading/journal.py +++ b/src/trading/journal.py @@ -473,6 +473,7 @@ def update_trade(trade_id: int, updates: dict): def get_open_trades_summary() -> dict: """Get summary of all open trades grouped by ticker""" + print("\n=== Fetching Open Trades Summary ===") # Debug with create_client() as client: query = """ SELECT @@ -496,10 +497,19 @@ def get_open_trades_summary() -> dict: HAVING total_shares > 0 ORDER BY ticker ASC """ - result = client.query(query).result_rows - columns = ['ticker', 'total_shares', 'avg_entry_price', - 'first_entry', 'last_entry', 'num_orders', 'position_ids'] - return [dict(zip(columns, row)) for row in result] + print(f"Executing summary query: {query}") # Debug + try: + result = client.query(query).result_rows + print(f"Summary query returned {len(result)} rows") # Debug + + columns = ['ticker', 'total_shares', 'avg_entry_price', + 'first_entry', 'last_entry', 'num_orders', 'position_ids'] + summaries = [dict(zip(columns, row)) for row in result] + print(f"Processed summaries: {summaries}") # Debug + return summaries + except Exception as e: + print(f"Error in get_open_trades_summary: {str(e)}") # Debug + raise def get_open_trades(): with create_client() as client: