Skip to content

Commit 1b88b31

Browse files
Use oncommit for celery sub task
1 parent 98b323a commit 1b88b31

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

backend/StreamServerApp/database_utils.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -211,7 +211,8 @@ def add_one_video_to_database(full_path, video_path, root, remote_url, filename,
211211

212212
v.save()
213213

214-
get_subtitles_async.delay(v.id, video_infos['has_ov_subtitle'])
214+
#we use oncommit because autocommit is not enabled.
215+
transaction.on_commit(lambda: get_subtitles_async.delay(v.id, video_infos['has_ov_subtitle']))
215216

216217
return return_value
217218

0 commit comments

Comments
 (0)