code: def search_raylet(cluster):
      """Return the number of running processes."""
      raylets = []
      for node in cluster.list_all_nodes():
          procs = node.all_processes
          raylet_proc_info = procs.get(
              ray_constants.PROCESS_TYPE_RAYLET
          )
          if raylet_proc_info:
              assert len(raylet_proc_info) == 1
              raylet = psutil.Process(raylet_proc_info[0].process.pid)
              if raylet.status() == "running":
                  raylets.append(
                      psutil.Process(raylet_proc_info[0].process.pid)
                  )
      return raylets
  
imports: import subprocess
  import sys
  import time
  import grpc
  import numpy
  import psutil
  import pytest
  from grpc._channel import _InactiveRpcError
  from ray.util.state import list_tasks
  from ray._private.state_api_test_utils import verify_failed_task
  import ray
  import ray._private.ray_constants
  import ray.experimental.internal_kv
  from ray import NodeID
  from ray._private.test_utils import SignalActor, get_error_message, init_error_pubsub, run_string_as_driver, wait_for_condition, kill_raylet
  from ray.cluster_utils import Cluster, cluster_not_supported
  from ray.core.generated import gcs_service_pb2, gcs_service_pb2_grpc, node_manager_pb2, node_manager_pb2_grpc
  from ray.exceptions import LocalRayletDiedError
label_desc: Use image node_id 1 for calling a global function with example usage: search_raylet(cluster) and returns: raylets