Skip to content

Commit a20adac

Browse files
Add error alerts
1 parent 50fe887 commit a20adac

File tree

1 file changed

+12
-7
lines changed

1 file changed

+12
-7
lines changed

scheduled_jobs.py

Lines changed: 12 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -31,20 +31,25 @@ def process_orders(app):
3131

3232
app.logger.info(f"Request payload: {payload}")
3333

34-
response = requests.post(
35-
app.config["FINANCE_PACKAGE_URL"] + "/ProcessPayment",
36-
json=payload
37-
)
34+
try:
35+
response = requests.post(
36+
app.config["FINANCE_PACKAGE_URL"] + "/ProcessPayment",
37+
json=payload
38+
)
3839

39-
app.logger.info("Response from endpoint: " + response.text)
4040

41-
response.raise_for_status()
41+
app.logger.info("Response from endpoint: " + response.text)
42+
43+
response.raise_for_status()
44+
except:
45+
app.logger.exception("Error processing order {id}".format(id = order.id))
4246

4347
order.set_as_processed()
4448
save_order(order)
4549

50+
4651
def get_queue_of_orders_to_process():
4752
allOrders = get_all_orders()
4853
queuedOrders = filter(lambda order: order.date_processed == None, allOrders)
49-
sortedQueue = sorted(queuedOrders, key= lambda order: order.date_placed)
54+
sortedQueue = sorted(queuedOrders, key=lambda order: order.date_placed)
5055
return list(sortedQueue)

0 commit comments

Comments
 (0)