code: def test_logs_streaming_error(self, mock_subprocess_popen):
      chief_config = machine_config.COMMON_MACHINE_CONFIGS["CPU"]
      worker_config = machine_config.COMMON_MACHINE_CONFIGS["TPU"]
      worker_count = 1
  
      mock_subprocess_popen.side_effect = ValueError("error")
      self.stream_logs = True
  
      with self.assertRaises(ValueError):
          deploy.deploy_job(
              self.docker_img,
              chief_config,
              worker_count,
              worker_config,
              self.entry_point_args,
              self.stream_logs,
          )
  
file_path: cloud/src/python/tensorflow_cloud/core/tests/unit/deploy_test.py
imports: import io
  from absl.testing import absltest
  from googleapiclient import discovery
  from googleapiclient import errors
  import mock
  from tensorflow_cloud.core import deploy
  from tensorflow_cloud.core import gcp
  from tensorflow_cloud.core import machine_config
  from tensorflow_cloud.utils import google_api_client
label_desc: Use image node_id 9 for calling the TestDeploy obj's underlying member method code with example usage: obj.test_logs_streaming_error(mock_subprocess_popen) without return types