I'm trying to read the runtimes of tasks after the pipeline finished, for analytics. currently, I'm doing something like this:

def collect_task_data(pipe: PipelineController):
    pipe_dag = pipe.get_pipeline_dag()

    def process_task(node_task):
        node, task = node_task
        exp_type = _extract_experiment_type_from_task_name(node)
        runtime = None
        if task.job is not None:
            runtime = task.job.task.data.active_duration
        return exp_type, task.status, runtime

    processed_data = list(map(process_task, pipe_dag.items()))

I'm getting None values for active_duration, job_started and job_ended in all tasks (also on completed ones).
what am I missing?