Skip to content

Commit 3d6f6c3

Browse files
committed
add TRN
1 parent c5d338d commit 3d6f6c3

File tree

1 file changed

+8
-5
lines changed

1 file changed

+8
-5
lines changed

qiita_db/analysis.py

Lines changed: 8 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -222,12 +222,15 @@ def create(
222222
"categories": categories,
223223
},
224224
)
225+
225226
job = qdb.processing_job.ProcessingJob.create(owner, params, True)
226-
sql = """INSERT INTO qiita.analysis_processing_job
227-
(analysis_id, processing_job_id)
228-
VALUES (%s, %s)"""
229-
qdb.sql_connection.TRN.add(sql, [a_id, job.id])
230-
qdb.sql_connection.TRN.execute()
227+
228+
with qdb.sql_connection.TRN:
229+
sql = """INSERT INTO qiita.analysis_processing_job
230+
(analysis_id, processing_job_id)
231+
VALUES (%s, %s)"""
232+
qdb.sql_connection.TRN.add(sql, [a_id, job.id])
233+
qdb.sql_connection.TRN.execute()
231234

232235
job.submit()
233236

0 commit comments

Comments
 (0)