@@ -417,7 +417,7 @@ def _remove_archive_locale(archive_clazz_locale, document_id, lang=None):
417417 archive_document_locale_ids = query .subquery ()
418418 DBSession .execute (archive_clazz_locale .__table__ .delete ().where (
419419 getattr (archive_clazz_locale , 'id' ).in_ (
420- archive_document_locale_ids )
420+ archive_document_locale_ids . select () )
421421 ))
422422
423423 query = DBSession .query (ArchiveDocumentLocale ). \
@@ -435,12 +435,12 @@ def _remove_locale(clazz_locale, document_id, lang=None):
435435 document_locale_ids = query .subquery ()
436436 # Remove links to comments (comments themselves are not removed)
437437 DBSession .execute (DocumentTopic .__table__ .delete ().where (
438- DocumentTopic .document_locale_id .in_ (document_locale_ids )
438+ DocumentTopic .document_locale_id .in_ (document_locale_ids . select () )
439439 ))
440440
441441 if clazz_locale :
442442 DBSession .execute (clazz_locale .__table__ .delete ().where (
443- getattr (clazz_locale , 'id' ).in_ (document_locale_ids )
443+ getattr (clazz_locale , 'id' ).in_ (document_locale_ids . select () )
444444 ))
445445
446446 query = DBSession .query (DocumentLocale ). \
@@ -467,7 +467,7 @@ def _remove_archive(archive_clazz, document_id):
467467 filter (ArchiveDocument .document_id == document_id ). \
468468 subquery ()
469469 DBSession .execute (archive_clazz .__table__ .delete ().where (
470- getattr (archive_clazz , 'id' ).in_ (archive_document_ids )
470+ getattr (archive_clazz , 'id' ).in_ (archive_document_ids . select () )
471471 ))
472472
473473 DBSession .query (ArchiveDocument ). \
0 commit comments