kopia lustrzana https://github.com/bugout-dev/moonstream
Merge pull request #626 from bugout-dev/add-select-to-query-background-task
Add try select 1pull/629/head
commit
e7d8245f94
|
@ -59,6 +59,11 @@ def data_generate(
|
||||||
|
|
||||||
with yield_db_read_only_session_ctx() as db_session:
|
with yield_db_read_only_session_ctx() as db_session:
|
||||||
|
|
||||||
|
try:
|
||||||
|
db_session.execute("SELECT 1")
|
||||||
|
except Exception as e:
|
||||||
|
db_session.rollback()
|
||||||
|
|
||||||
if file_type == "csv":
|
if file_type == "csv":
|
||||||
csv_buffer = StringIO()
|
csv_buffer = StringIO()
|
||||||
csv_writer = csv.writer(csv_buffer, delimiter=";")
|
csv_writer = csv.writer(csv_buffer, delimiter=";")
|
||||||
|
|
Ładowanie…
Reference in New Issue