Open
Description
While working on battle testing for observability to inspect expected spans, I wrote this code
def tx_dql_select(tx):
return tx.execute_sql("SELECT * FROM Singers")
fn = tx_dql_select
try:
result = database.run_in_transaction(fn)
if result and hasattr(result, "__iter__"):
for res in result:
print(res)
except Exception as e:
print(fn.__name__, e)which produces
tx_dql_select Transaction is not begunbut when I add tx.begin() before the return I get back
tx_dql_select Transaction is already committedIt seems impossible to use, we need to figure out what's up. I should be able to run purely DQL in a transaction.
Kindly cc-ing @sakthivelmanii @harshachinta