code: def __init__(self, interval_s=1, total_steps=3):
      self.interval_s = interval_s
      self.stopped = False
      self.current_step = 1
      self.total_steps = total_steps
  
      worker = ray._private.worker.global_worker
      worker_id = worker.core_worker.get_actor_id()
      ray_kv._internal_kv_put(
          f"JOB:{worker_id}", self.current_step, overwrite=True
      )
  
file_path: ray/python/ray/experimental/job/example_job/demo_script.py
imports: import argparse
  import time
  import ray
  import ray.experimental.internal_kv
label_desc: Use image node_id 1 to create a new StepActor object  with example: obj = StepActor(interval_s, total_steps)