code: def add_no_delay_tasks_source(source, benchmark, number_of_cores):
      scheduler_type = benchmark["scheduler_type"]
      if benchmark["benchmark_type"] not in source:
          source[benchmark["benchmark_type"]] = {
              scheduler_type: get_value_dict(engines_or_cores="cores")
          }
      if scheduler_type not in source[benchmark["benchmark_type"]]:
          source[benchmark["benchmark_type"]][
              scheduler_type
          ] = get_value_dict(engines_or_cores="cores")
      dict_to_append_to = source[benchmark["benchmark_type"]][
          scheduler_type
      ]
  
      for duration, tasks_num in [
          (result.duration_in_ms, result.number_of_tasks)
          for result in benchmark["results"]
          if not result.failed
      ]:
          dict_to_append_to["Duration in ms"].append(duration)
          dict_to_append_to["Number of tasks"].append(tasks_num)
          dict_to_append_to["Number of cores"].append(number_of_cores)
  
imports: import json
  import os
  import pickle
  import re
  from datetime import datetime
  from enum import Enum
  from itertools import product
  from utils import seconds_to_ms
  from benchmarks.constants import DEFAULT_NUMBER_OF_ENGINES
label_desc: Use image node_id 8 for calling a global function with example usage: add_no_delay_tasks_source(source, benchmark, number_of_cores) without return types