code: def image_pipeline():
      run = wandb.init(project="ray-prefect")
      logger = prefect.get_run_logger()
  
      image_path_futures = generate_random_image.map(range(10))
      # resolve futures
      image_paths = [str(f.result()) for f in image_path_futures]
  
      logger.info(f"raw image paths: {image_paths}")
  
      # get brightest pixel
      combined_image_path = combine_images(image_path_futures)
      logger.info(f"combined image path: {combined_image_path}")
      run.log(
          {
              "combined_image": wandb.Image(
                  plt.imread(combined_image_path)
              )
          }
      )
      run.finish()
  
file_path: wandb/tests/functional_tests/t0_main/prefect_ray/t1_prefect_ray_workflow.py
imports: import argparse
  import os
  import pathlib
  from typing import List
  import matplotlib.pyplot
  import numpy
  import prefect
  import prefect.task_runners
  import prefect_ray
  import wandb
label_desc: Use image node_id 3 for calling a global function with example usage: image_pipeline() without return types