code: def test_end_to_end_preempting(relay_server, wandb_init):
      with relay_server() as relay:
          run = wandb_init(settings=dict(console="off"))
          run.mark_preempting()
  
          # poll for message arrival
          for _ in range(3):
              preempting = relay.context.entries[run.id].get(
                  "preempting"
              )
              if preempting:
                  break
              time.sleep(1)
          print(relay.context.raw_data)
          assert any(preempting)
          run.finish()
  
file_path: wandb/tests/pytest_tests/system_tests/test_core/test_wandb_integration.py
imports: import importlib
  import os
  import shutil
  import time
  from unittest import mock
  import pytest
  import wandb
  import wandb.env
label_desc: Use image node_id 9 for calling a global function with example usage: test_end_to_end_preempting(relay_server, wandb_init) without return types