Method spawn_new_task

app/src/deployment_manager/task_context.rs:14–33

(task: Arc<dyn Task>)

impl TaskContext {
    pub fn spawn_new_task(task: Arc<dyn Task>) -> TaskContext {
        let span = Span::current();

        let task_handle = tokio_utils::launch_blocking_task({
            let task = task.clone();
            move || {
                let _guard = scopeguard::guard(span, |span| {
                    let _span = span.enter();
                    debug!("Task {} has terminated to run from blocking pool", task.id());
                });

                task.run();
            }
        });

        TaskContext {
            task,
            _handle: task_handle,
        }
    }

    pub async fn terminate_task(self) {
        if self.task.is_terminated() {