Skip to content

Commit c1ff5a7

Browse files
committed
ct/l1/metastore: check abort source when purging
In the rapid topic creation test, it's seen that shutdown hangs with the topic purger, and I think it is due to we see 100 topics we need to purge, and with a timeout of 5 seconds each, it's probably pretty easy to blow past our shutdown timeouts. I wish our RPC system supported abort_sources.
1 parent 3d3f04b commit c1ff5a7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/v/cloud_topics/level_one/metastore/topic_purger.cc

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,8 @@ topic_purger::purge_tombstoned_topics(ss::abort_source* as) {
9494
ss::max_concurrent_for_each(
9595
ntrs_to_purge,
9696
max_concurrent_purges,
97-
[this, &first_error](const cluster::nt_revision& ntr) {
97+
[this, as, &first_error](const cluster::nt_revision& ntr) {
98+
as->check();
9899
return remove_tombstone_(ntr).then(
99100
[&first_error](
100101
const topic_purger::remove_tombstone_ret_t& ret) {

0 commit comments

Comments
 (0)