code: def test_create_subscription_with_ack_deadline(self, mock_service):
      create_method = mock_service.create_subscription
  
      response = self.pubsub_hook.create_subscription(
          project_id=TEST_PROJECT,
          topic=TEST_TOPIC,
          subscription=TEST_SUBSCRIPTION,
          ack_deadline_secs=30,
      )
      create_method.assert_called_once_with(
          request=dict(
              name=EXPANDED_SUBSCRIPTION,
              topic=EXPANDED_TOPIC,
              push_config=None,
              ack_deadline_seconds=30,
              retain_acked_messages=None,
              message_retention_duration=None,
              labels=LABELS,
              enable_message_ordering=False,
              expiration_policy=None,
              filter=None,
              dead_letter_policy=None,
              retry_policy=None,
          ),
          retry=DEFAULT,
          timeout=None,
          metadata=(),
      )
      assert TEST_SUBSCRIPTION == response
  
imports: from __future__ import annotations
  from unittest import mock
  from uuid import UUID
  import httplib2
  import pytest
  from google.api_core.exceptions import AlreadyExists, GoogleAPICallError
  from google.api_core.gapic_v1.method import DEFAULT
  from google.cloud.exceptions import NotFound
  from google.cloud.pubsub_v1.types import ReceivedMessage
  from googleapiclient.errors import HttpError
  from airflow.providers.google.cloud.hooks.pubsub import PubSubAsyncHook, PubSubException, PubSubHook
  from airflow.providers.google.common.consts import CLIENT_INFO
  from airflow.version import version
label_desc: Use image node_id 18 for calling the TestPubSubHook obj's underlying member method code with example usage: obj.test_create_subscription_with_ack_deadline(mock_service) without return types