Skip to content

Skip sending error message for fail graph requests #10

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.

Sign up for GitHub

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

Merged
tapired merged 2 commits into from
Aug 14, 2024
Merged

Skip sending error message for fail graph requests #10

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
a4f7bd3
Skip sending error message for fail graph requests
spalen0 Aug 14, 2024
4d0c379
Cleanup
spalen0 Aug 14, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
30 changes: 15 additions & 15 deletions silo/main.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -25,9 +25,7 @@ def fetch_high_risk_silo_positions(subgraph_id):
skip: $skip,
where: { riskFactor_gt: "1", isActive: true }
) {
id
totalBorrowValue
totalCollateralValue
totalLiquidationThresholdValue
riskFactor
silo {
Expand All @@ -47,18 +45,20 @@ def fetch_high_risk_silo_positions(subgraph_id):
"first": first,
"skip": skip
}
try:
response = run_query(query, variables, subgraph_id)
if 'errors' in response:
send_telegram_message(f"GraphQL errors: {json.dumps(response['errors'], indent=2)}")

new_positions = response['data']['siloPositions']
high_risk_positions.extend(new_positions)
skip += len(new_positions)

except Exception as e:
send_telegram_message(f"An error occurred: {str(e)}")

response = run_query(query, variables, subgraph_id)
if 'errors' in response:
# don't send message or raise exception because graph is reliable
return high_risk_positions
if 'data' not in response:
# don't send message or raise exception because graph is reliable
# send_telegram_message(f"Unexpected response: {json.dumps(response, indent=2)}")
return high_risk_positions

new_positions = response['data']['siloPositions']
if not new_positions:
break
high_risk_positions.extend(new_positions)
skip += len(new_positions)
return high_risk_positions

# Function to calculate total bad debt
Expand Down Expand Up @@ -89,7 +89,7 @@ def process_silo(subgraph_id, network_name):
# Base beep bop message
message = "🚨 **Bad Debt Report** 🚨\n"
message += f"⛓️ Silo on {network_name}\n"

has_bad_debt = False
for silo_id, bad_debt in total_bad_debts.items():
if bad_debt > 0:
has_bad_debt = True
Expand Down