code: def __init__(self, cluster_manager: ClusterManager):
      self.start_time = None
      self.counter = 0
      self.cluster_manager = cluster_manager
      self._last_job_result = None
      self._last_logs = None
      self.cluster_startup_timeout = 600
      self._duration = None
  
imports: import os
  import time
  import subprocess
  import tempfile
  from collections import deque
  from contextlib import contextmanager
  from typing import Any, Dict, Optional, Tuple, List
  from anyscale.sdk.anyscale_client.models import CreateProductionJob, HaJobStates
  from ray_release.anyscale_util import LAST_LOGS_LENGTH, get_cluster_name
  from ray_release.cluster_manager.cluster_manager import ClusterManager
  from ray_release.exception import CommandTimeout, JobStartupTimeout, JobStartupFailed
  from ray_release.logger import logger
  from ray_release.signal_handling import register_handler, unregister_handler
  from ray_release.util import ANYSCALE_HOST, ERROR_LOG_PATTERNS, exponential_backoff_retry, anyscale_job_url, format_link
label_desc: Use image node_id 1 to create a new AnyscaleJobManager object  with example: obj = AnyscaleJobManager(cluster_manager)