diff --git a/compaction/task_manager_module.hh b/compaction/task_manager_module.hh
index 7dbcf98c8f..8f08ded2ad 100644
--- a/compaction/task_manager_module.hh
+++ b/compaction/task_manager_module.hh
@@ -707,6 +707,10 @@ public:
     virtual std::string type() const override {
         return "regular compaction";
     }
+
+    virtual tasks::is_internal is_internal() const noexcept override {
+        return tasks::is_internal::yes;
+    }
 protected:
     virtual future<> run() override = 0;
 };
diff --git a/test/rest_api/test_compaction_task.py b/test/rest_api/test_compaction_task.py
index dd1b855638..806cbda0a7 100644
--- a/test/rest_api/test_compaction_task.py
+++ b/test/rest_api/test_compaction_task.py
@@ -5,7 +5,7 @@ import threading
 sys.path.insert(1, sys.path[0] + '/../cql-pytest')
 from util import new_test_table, new_test_keyspace
 from rest_util import set_tmp_task_ttl, scylla_inject_error
-from task_manager_utils import wait_for_task, list_tasks, check_child_parent_relationship, drain_module_tasks, abort_task
+from task_manager_utils import wait_for_task, list_tasks, check_child_parent_relationship, drain_module_tasks, abort_task, get_task_status
 
 module_name = "compaction"
 long_time = 1000000000
@@ -106,27 +106,6 @@ def test_resharding_compaction_task(cql, this_dc, rest_api):
     check_compaction_task(cql, this_dc, rest_api, lambda keyspace, table: rest_api.send("POST", f"storage_service/sstables/{keyspace}", {'cf': table, 'load_and_stream': False}), "resharding compaction", task_tree_depth, True)
 
 def test_regular_compaction_task(cql, this_dc, rest_api):
-    drain_module_tasks(rest_api, module_name)
-    with set_tmp_task_ttl(rest_api, long_time):
-        with new_test_keyspace(cql, f"WITH REPLICATION = {{ 'class' : 'NetworkTopologyStrategy', '{this_dc}' : 1 }}") as keyspace:
-            schema = 'p int, v text, primary key (p)'
-            with new_test_table(cql, keyspace, schema) as t0:
-                stmt = cql.prepare(f"INSERT INTO {t0} (p, v) VALUES (?, ?)")
-                cql.execute(stmt, [0, 'hello'])
-                cql.execute(stmt, [1, 'world'])
-
-                [_, table] = t0.split(".")
-                resp = rest_api.send("POST", f"column_family/autocompaction/{keyspace}:{table}")
-                resp.raise_for_status()
-
-                statuses = [wait_for_task(rest_api, task["task_id"]) for task in list_tasks(rest_api, "compaction") if task["type"] == "regular compaction" and task["keyspace"] == keyspace and task["table"] == table]
-                assert statuses, f"regular compaction task for {t0} was not created"
-
-                failed = [status["task_id"] for status in statuses if status["state"] != "done"]
-                assert not failed, f"Regular compaction tasks with ids = {failed} failed"
-    drain_module_tasks(rest_api, module_name)
-
-def test_running_compaction_task_abort(cql, this_dc, rest_api):
     drain_module_tasks(rest_api, module_name)
     with set_tmp_task_ttl(rest_api, long_time):
         with new_test_keyspace(cql, f"WITH REPLICATION = {{ 'class' : 'NetworkTopologyStrategy', '{this_dc}' : 1 }}") as keyspace:
@@ -142,22 +121,15 @@ def test_running_compaction_task_abort(cql, this_dc, rest_api):
                     resp = rest_api.send("POST", f"column_family/autocompaction/{keyspace}:{table}")
                     resp.raise_for_status()
 
-                    tasks = [task for task in list_tasks(rest_api, module_name, False, keyspace, table) if task["type"] == "regular compaction"]
-                    assert tasks, "Compaction task was not created"
-
-                    for task in tasks:
-                        abort_task(rest_api, task["task_id"])
+                    statuses = [get_task_status(rest_api, task["task_id"]) for task in list_tasks(rest_api, "compaction", internal=True) if task["type"] == "regular compaction" and task["keyspace"] == keyspace and task["table"] == table]
+                    assert statuses, f"regular compaction task for {t0} was not created"
+                    assert all([s["state"] != "done" and s["state"] != "failed" for s in statuses]), "Regular compaction task isn't unregiatered after it completes"
 
                     resp = rest_api.send("POST", f"v2/error_injection/injection/{injection}/message")
                     resp.raise_for_status()
-
-                    statuses = [wait_for_task(rest_api, task["task_id"]) for task in tasks]
-                    aborted = [status for status in statuses if "abort requested" in status["error"]]
-                    assert aborted, "Task wasn't aborted by user"
-                    assert all([status["state"] == "failed" for status in aborted]), "Task finished successfully"
     drain_module_tasks(rest_api, module_name)
 
-def test_not_created_compaction_task_abort(cql, this_dc, rest_api):
+def test_compaction_task_abort(cql, this_dc, rest_api):
     drain_module_tasks(rest_api, module_name)
     with set_tmp_task_ttl(rest_api, long_time):
         with new_test_keyspace(cql, f"WITH REPLICATION = {{ 'class' : 'NetworkTopologyStrategy', '{this_dc}' : 1 }}") as keyspace: