pub async fn complete(self, timeout: Duration) {
        if tokio::time::timeout(timeout, self.complete_inner())
            .await
            .is_err()
        {
            tracing::warn!("Failed to terminate actors in {timeout:?}");
        }
    }
Drives all remaining tasks to completion, logging their errors / panics should they occur.
core/lib/task_management/src/lib.rs