code: def test_workflow_with_pressure(workflow_start_regular_shared):
      pressure_level = 10
  
      dags = [
          generate_chain(),
          generate_continuation(),
          generate_random_dag(gather_and_hash),
          generate_layered_dag(gather_and_hash),
      ]
  
      ans = ray.get([d.execute() for d in dags])
      outputs = []
      for _ in range(pressure_level):
          for w in dags:
              outputs.append(workflow.run_async(w))
  
      assert ray.get(outputs) == ans * pressure_level
  
file_path: ray/python/ray/workflow/tests/test_complex_workflow.py
imports: import pytest
  import random
  import ray
  from ray import workflow
label_desc: Use image node_id 6 for calling a global function with example usage: test_workflow_with_pressure(workflow_start_regular_shared) without return types