diff --git a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveTableBasedDeleteHandler.java b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveTableBasedDeleteHandler.java
index c27fbf502..66a6ee910 100644
--- a/hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveTableBasedDeleteHandler.java
+++ b/hibernate-reactive-core/src/main/java/org/hibernate/reactive/query/sqm/mutation/internal/temptable/ReactiveTableBasedDeleteHandler.java
@@ -98,14 +98,12 @@ public CompletionStage<Integer> reactiveExecute(JdbcParameterBindings jdbcParame
 
 	private CompletionStage<Void> deleteRows(JdbcParameterBindings jdbcParameterBindings, StandardReactiveJdbcMutationExecutor jdbcMutationExecutor, SqmJdbcExecutionContextAdapter executionContext, int[] rows) {
 		if ( getEntityDescriptor() instanceof UnionSubclassEntityPersister ) {
-			return CompletionStages
-					.loop( getDeletes(), delete -> reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
+			return loop( getDeletes(), delete -> reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
 						.thenApply( tot -> rows[0] += tot )
 					);
 		}
 		else {
-			return CompletionStages
-					.loop( getDeletes(), delete -> reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
+			return loop( getDeletes(), delete -> reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
 						.thenApply( tot -> rows[0] = tot )
 					);
 		}
@@ -128,8 +126,10 @@ private CompletionStage<Integer> executeDelete(
 			);
 		}
 		return loop( getCollectionTableDeletes(), delete ->
-						reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
-		).thenApply( v -> rows );
+				reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
+		).thenCompose( v -> loop( getDeletes(), delete ->
+				reactiveExecute( jdbcParameterBindings, delete, jdbcMutationExecutor, executionContext )
+		) ).thenApply( v -> rows );
 	}
 
 	private static CompletionStage<Integer> reactiveExecute(
diff --git a/hibernate-reactive-core/src/test/java/org/hibernate/reactive/JoinedSubclassInheritanceTest.java b/hibernate-reactive-core/src/test/java/org/hibernate/reactive/JoinedSubclassInheritanceTest.java
index 432535b51..d12e4aded 100644
--- a/hibernate-reactive-core/src/test/java/org/hibernate/reactive/JoinedSubclassInheritanceTest.java
+++ b/hibernate-reactive-core/src/test/java/org/hibernate/reactive/JoinedSubclassInheritanceTest.java
@@ -212,6 +212,29 @@ public void testHqlInsertWithTransaction(VertxTestContext context) {
 		);
 	}
 
+	@Test
+	public void testHqlDelete(VertxTestContext context) {
+		final Integer id = 1;
+		final String title = "Spell Book: A Comprehensive Guide to Magic Spells and Incantations";
+		SpellBook spellBook = new SpellBook( id, title, true, new Date() );
+		test( context, getMutinySessionFactory().withTransaction( session -> session.persist( spellBook ) )
+				.call( () -> getMutinySessionFactory().withTransaction( session -> session
+						.createMutationQuery(
+								"delete from SpellBook where id = :id and forbidden = :forbidden and title = :title" )
+						.setParameter( "id", id )
+						.setParameter( "title", title )
+						.setParameter( "forbidden", true )
+						.executeUpdate() )
+				)
+				.call( () -> getMutinySessionFactory().withTransaction( session -> session
+						.createSelectionQuery( "from SpellBook g where g.id = :id ", SpellBook.class )
+						.setParameter( "id", id )
+						.getSingleResultOrNull()
+						.invoke( Assertions::assertNull ) )
+				)
+		);
+	}
+
 	@Entity(name="SpellBook")
 	@Table(name = "SpellBookJS")
 	@DiscriminatorValue("S")