code: def _create_db_instance_snapshot(hook: RdsHook):
      _create_db_instance(hook)
      hook.conn.create_db_snapshot(
          DBInstanceIdentifier=DB_INSTANCE_NAME,
          DBSnapshotIdentifier=DB_INSTANCE_SNAPSHOT,
      )
      if not hook.conn.describe_db_snapshots()["DBSnapshots"]:
          raise ValueError("AWS not properly mocked")
  
imports: from __future__ import annotations
  from moto import mock_rds
  from airflow.models import DAG
  from airflow.providers.amazon.aws.hooks.rds import RdsHook
  from airflow.providers.amazon.aws.sensors.rds import RdsBaseSensor, RdsDbSensor, RdsExportTaskExistenceSensor, RdsSnapshotExistenceSensor
  from airflow.providers.amazon.aws.utils.rds import RdsDbType
  from airflow.utils import timezone
label_desc: Use image node_id 2 for calling a global function with example usage: _create_db_instance_snapshot(hook) without return types