srht.webhook: fix SQLalchemy usage

This commit is contained in:
Drew DeVault 2024-03-20 16:24:59 +01:00
parent 022492145b
commit 26438e80a8
1 changed files with 15 additions and 14 deletions

View File

@ -48,20 +48,21 @@ def make_worker(broker='redis://'):
response_status = -1
response_headers = None
if delivery_table and delivery_id:
db.session.execute(
f"""
UPDATE {delivery_table}
SET response = :response,
response_status = :status,
response_headers = :headers
WHERE id = :delivery_id
""", {
"response": response,
"status": response_status,
"headers": response_headers,
"delivery_id": delivery_id
})
db.session.commit()
with db.engine.connect() as conn:
conn.execute(text(
f"""
UPDATE {delivery_table}
SET response = :response,
response_status = :status,
response_headers = :headers
WHERE id = :delivery_id
"""), {
"response": response,
"status": response_status,
"headers": response_headers,
"delivery_id": delivery_id
})
conn.commit()
return r
global _async_request