code: def mock_get_operation(self, expected_operation):
      get_operation_mock = mock.AsyncMock()
      get_operation_mock.return_value = expected_operation
      return get_operation_mock
  
imports: from __future__ import annotations
  from unittest import mock
  import pytest
  from google.cloud.run_v2 import CreateJobRequest, GetJobRequest, Job, ListJobsRequest, RunJobRequest, UpdateJobRequest
  from airflow.exceptions import AirflowException
  from airflow.providers.google.cloud.hooks.cloud_run import CloudRunAsyncHook, CloudRunHook
  from tests.providers.google.cloud.utils.base_gcp_mock import mock_base_gcp_hook_default_project_id
label_desc: Use image node_id 1 for calling the TestCloudRunAsyncHook obj's underlying member method code with example usage: obj.mock_get_operation(expected_operation) and returns: get_operation_mock