code: def test_import_from_storage_bucket(self, mock_get_conn):
      self.datastore_hook.admin_connection = mock_get_conn.return_value
      bucket = "bucket"
      file = "file"
      namespace = None
      entity_filter = {}
      labels = {}
  
      resp = self.datastore_hook.import_from_storage_bucket(
          bucket=bucket,
          file=file,
          namespace=namespace,
          entity_filter=entity_filter,
          labels=labels,
          project_id=GCP_PROJECT_ID,
      )
  
      projects = self.datastore_hook.admin_connection.projects
      projects.assert_called_once_with()
      import_ = projects.return_value.import_
      import_.assert_called_once_with(
          projectId=GCP_PROJECT_ID,
          body={
              "inputUrl": "gs://"
              + "/".join(filter(None, [bucket, namespace, file])),
              "entityFilter": entity_filter,
              "labels": labels,
          },
      )
      execute = import_.return_value.execute
      execute.assert_called_once_with(num_retries=mock.ANY)
      assert resp == execute.return_value
  
imports: from __future__ import annotations
  from unittest import mock
  from unittest.mock import call, patch
  import pytest
  from airflow.exceptions import AirflowException
  from airflow.providers.google.cloud.hooks.datastore import DatastoreHook
label_desc: Use image node_id 21 for calling the TestDatastoreHook obj's underlying member method code with example usage: obj.test_import_from_storage_bucket(mock_get_conn) without return types