code: def test_workflow_status_update(workflow_start_regular):
      # Test workflow status update is working.
      @client_mode_wrap
      def check():
          store = WorkflowIndexingStorage()
          assert not store.list_workflow()
          for i in range(100):
              assert (
                  store.load_workflow_status(workflow_id=str(i))
                  == WorkflowStatus.NONE
              )
  
          for i in range(100):
              store.update_workflow_status(
                  str(i), WorkflowStatus.RUNNING
              )
  
          assert sorted(store.list_workflow()) == sorted(
              [(str(i), WorkflowStatus.RUNNING) for i in range(100)]
          )
  
          assert sorted(
              store.list_workflow({WorkflowStatus.RUNNING})
          ) == sorted(
              [(str(i), WorkflowStatus.RUNNING) for i in range(100)]
          )
  
          assert (
              sorted(store.list_workflow({WorkflowStatus.RESUMABLE}))
              == []
          )
  
          for i in range(100):
              store.update_workflow_status(
                  str(i), WorkflowStatus.RESUMABLE
              )
  
          assert sorted(
              store.list_workflow({WorkflowStatus.RESUMABLE})
          ) == sorted(
              [(str(i), WorkflowStatus.RESUMABLE) for i in range(100)]
          )
  
          assert (
              sorted(store.list_workflow({WorkflowStatus.FAILED})) == []
          )
  
          for i in range(100):
              store.update_workflow_status(
                  str(i), WorkflowStatus.FAILED
              )
  
          assert sorted(store.list_workflow()) == sorted(
              [(str(i), WorkflowStatus.FAILED) for i in range(100)]
          )
  
          assert sorted(
              store.list_workflow({WorkflowStatus.FAILED})
          ) == sorted(
              [(str(i), WorkflowStatus.FAILED) for i in range(100)]
          )
  
          assert (
              sorted(store.list_workflow({WorkflowStatus.RUNNING}))
              == []
          )
  
      check()
  
imports: import pytest
  from ray._private.client_mode_hook import client_mode_wrap
  from ray.workflow.common import WorkflowStatus
  from ray.workflow.workflow_storage import WorkflowIndexingStorage
label_desc: Use image node_id 1 for calling a global function with example usage: test_workflow_status_update(workflow_start_regular) without return types