code: def _assert_executed_jobs_xcom(ti):
      job1_dicts = ti.xcom_pull(
          task_ids=[execute1_task_name], key="return_value"
      )
      assert job1_name in job1_dicts[0]["name"]
  
      job2_dicts = ti.xcom_pull(
          task_ids=[execute2_task_name], key="return_value"
      )
      assert job2_name in job2_dicts[0]["name"]
  
      job3_dicts = ti.xcom_pull(
          task_ids=[execute3_task_name], key="return_value"
      )
      assert job3_name in job3_dicts[0]["name"]
  
file_path: airflow/tests/system/providers/google/cloud/cloud_run/example_cloud_run.py
imports: from __future__ import annotations
  import os
  from datetime import datetime
  from google.cloud.run_v2 import Job
  from google.cloud.run_v2.types import k8s_min
  from airflow.models.dag import DAG
  from airflow.operators.python import PythonOperator
  from airflow.providers.google.cloud.operators.cloud_run import CloudRunCreateJobOperator, CloudRunDeleteJobOperator, CloudRunExecuteJobOperator, CloudRunListJobsOperator, CloudRunUpdateJobOperator
  from airflow.utils.trigger_rule import TriggerRule
  from tests.system.utils import get_test_run
label_desc: Use image node_id 1 for calling a global function with example usage: _assert_executed_jobs_xcom(ti) without return types