code: def test_concurrent_bucket_modification(sagemaker_session):
      message = "A conflicting conditional operation is currently in progress against this resource. Please try again"
      error = ClientError(
          error_response={
              "Error": {"Code": "OperationAborted", "Message": message}
          },
          operation_name="foo",
      )
      sagemaker_session.boto_session.resource().create_bucket.side_effect = (
          error
      )
  
      bucket_name = sagemaker_session.default_bucket()
      assert bucket_name == DEFAULT_BUCKET_NAME
  
file_path: sagemaker-python-sdk/tests/unit/test_default_bucket.py
imports: from __future__ import absolute_import
  import datetime
  import pytest
  from botocore.exceptions import ClientError
  from mock import MagicMock
  import sagemaker
label_desc: Use image node_id 9 for calling a global function with example usage: test_concurrent_bucket_modification(sagemaker_session) without return types