code: def test_fstream_status_max_retries(
      relay_server,
      mock_run,
      publish_util,
      inject_file_stream_response,
  ):
      # set short max sleep so we can exhaust retries
      with unittest.mock.patch.object(
          wandb.sdk.internal.file_stream, "MAX_SLEEP_SECONDS", 1e-2
      ):
          run = mock_run(use_magic_mock=True)
          injected_response = inject_file_stream_response(
              run=run, status=500, application_pattern="1"
          )
          assert_history(
              relay_server,
              run,
              publish_util,
              inject=[injected_response],
              dropped=1,
          )
  
file_path: wandb/tests/pytest_tests/system_tests/test_core/test_file_stream_internal.py
imports: import json
  import unittest.mock
  import pytest
  import wandb
label_desc: Use image node_id 11 for calling a global function with example usage: test_fstream_status_max_retries(relay_server, mock_run, publish_util, inject_file_stream_response) without return types