diff --git a/.librarian/generator-input/owlbot.py b/.librarian/generator-input/owlbot.py
new file mode 100644
index 000000000..abaf534e2
--- /dev/null
+++ b/.librarian/generator-input/owlbot.py
@@ -0,0 +1,352 @@
+# Copyright 2022 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+import json
+from pathlib import Path
+import re
+import shutil
+import textwrap
+
+import synthtool as s
+import synthtool.gcp as gcp
+from synthtool.languages import python
+
+# ----------------------------------------------------------------------------
+# Copy the generated client from the owl-bot staging directory
+# ----------------------------------------------------------------------------
+
+clean_up_generated_samples = True
+
+# Load the default version defined in .repo-metadata.json.
+default_version = json.load(open(".repo-metadata.json", "rt")).get(
+    "default_version"
+)
+
+for library in s.get_staging_dirs(default_version):
+    if clean_up_generated_samples:
+        shutil.rmtree("samples/generated_samples", ignore_errors=True)
+        clean_up_generated_samples = False
+
+    # DEFAULT SCOPES and SERVICE_ADDRESS are being used. so let's force them in.
+    s.replace(
+        library / f"google/pubsub_{library.name}/services/*er/*client.py",
+        r"""DEFAULT_ENDPOINT = \"pubsub\.googleapis\.com\"""",
+        """
+    # The scopes needed to make gRPC calls to all of the methods defined in
+    # this service
+    _DEFAULT_SCOPES = (
+        'https://www.googleapis.com/auth/cloud-platform',
+        'https://www.googleapis.com/auth/pubsub',
+    )
+
+    SERVICE_ADDRESS = "pubsub.googleapis.com:443"
+    \"""The default address of the service.\"""
+
+    \g<0>""",
+    )
+
+    # Modify GRPC options in transports.
+    count = s.replace(
+        [
+            library / f"google/pubsub_{library.name}/services/*/transports/grpc*",
+            library / f"tests/unit/gapic/pubsub_{library.name}/*",
+        ],
+        "options=\[.*?\]",
+        """options=[
+                    ("grpc.max_send_message_length", -1),
+                    ("grpc.max_receive_message_length", -1),
+                    ("grpc.max_metadata_size", 4 * 1024 * 1024),
+                    ("grpc.keepalive_time_ms", 30000),
+                ]""",
+        flags=re.MULTILINE | re.DOTALL,
+    )
+
+    if count < 15:
+        raise Exception("Expected replacements for gRPC channel options not made.")
+
+    # If the emulator is used, force an insecure gRPC channel to avoid SSL errors.
+    clients_to_patch = [
+        library / f"google/pubsub_{library.name}/services/publisher/client.py",
+        library / f"google/pubsub_{library.name}/services/subscriber/client.py",
+        library / f"google/pubsub_{library.name}/services/schema_service/client.py",
+    ]
+    err_msg = (
+        "Expected replacements for gRPC channel to use with the emulator not made."
+    )
+
+    count = s.replace(clients_to_patch, r"import os", "import functools\n\g<0>")
+
+    if count < len(clients_to_patch):
+        raise Exception(err_msg)
+
+    count = s.replace(
+        clients_to_patch,
+        f"from \.transports\.base",
+        "\nimport grpc\n\g<0>",
+    )
+
+    if count < len(clients_to_patch):
+        raise Exception(err_msg)
+
+    # TODO(https://github.com/googleapis/python-pubsub/issues/1349): Move the emulator
+    # code below to test files.
+    count = s.replace(
+        clients_to_patch,
+        r"# initialize with the provided callable or the passed in class",
+        """\g<0>
+
+            emulator_host = os.environ.get("PUBSUB_EMULATOR_HOST")
+            if emulator_host:
+                if issubclass(transport_init, type(self)._transport_registry["grpc"]): # type: ignore
+                    channel = grpc.insecure_channel(target=emulator_host)
+                else:
+                    channel = grpc.aio.insecure_channel(target=emulator_host)
+                transport_init = functools.partial(transport_init, channel=channel)
+
+    """,
+    )
+
+    if count < len(clients_to_patch):
+        raise Exception(err_msg)
+
+    # Monkey patch the streaming_pull() GAPIC method to disable pre-fetching stream
+    # results.
+    s.replace(
+        library / f"google/pubsub_{library.name}/services/subscriber/client.py",
+        (
+            r"# Wrap the RPC method.*\n"
+            r"\s+# and friendly error.*\n"
+            r"\s+rpc = self\._transport\._wrapped_methods\[self\._transport\.streaming_pull\]"
+        ),
+        """
+        # Wrappers in api-core should not automatically pre-fetch the first
+        # stream result, as this breaks the stream when re-opening it.
+        # https://github.com/googleapis/python-pubsub/issues/93#issuecomment-630762257
+        self._transport.streaming_pull._prefetch_first_result_ = False
+
+        \g<0>""",
+    )
+
+    # Emit deprecation warning if return_immediately flag is set with synchronous pull.
+    s.replace(
+        library / f"google/pubsub_{library.name}/services/subscriber/*client.py",
+        r"from google.pubsub_v1 import gapic_version as package_version",
+        "import warnings\n\g<0>",
+    )
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/subscriber/*client.py",
+        r"""
+    ([^\n\S]+(?:async\ )?def\ pull\(.*?->\ pubsub\.PullResponse:.*?)
+    ((?P<indent>[^\n\S]+)\#\ Wrap\ the\ RPC\ method)
+    """,
+        textwrap.dedent(
+            """
+    \g<1>
+    \g<indent>if request.return_immediately:
+    \g<indent>    warnings.warn(
+    \g<indent>        "The return_immediately flag is deprecated and should be set to False.",
+    \g<indent>        category=DeprecationWarning,
+    \g<indent>    )
+
+    \g<2>"""
+        ),
+        flags=re.MULTILINE | re.DOTALL | re.VERBOSE,
+    )
+
+    if count != 2:
+        raise Exception("Too many or too few replacements in pull() methods.")
+
+    # Silence deprecation warnings in pull() method flattened parameter tests.
+    s.replace(
+        library / f"tests/unit/gapic/pubsub_{library.name}/test_subscriber.py",
+        "import os",
+        "\g<0>\nimport warnings",
+    )
+
+    count = s.replace(
+        library / f"tests/unit/gapic/pubsub_{library.name}/test_subscriber.py",
+        textwrap.dedent(
+            r"""
+        ([^\n\S]+# Call the method with a truthy value for each flattened field,
+        [^\n\S]+# using the keyword arguments to the method\.)
+        \s+(client\.pull\(.*?\))"""
+        ),
+        """\n\g<1>
+        with warnings.catch_warnings():
+            warnings.simplefilter("ignore", category=DeprecationWarning)
+            \g<2>""",
+        flags=re.MULTILINE | re.DOTALL,
+    )
+
+    if count < 1:
+        raise Exception("Catch warnings replacement failed.")
+
+    count = s.replace(
+        library / f"tests/unit/gapic/pubsub_{library.name}/test_subscriber.py",
+        textwrap.dedent(
+            r"""
+        ([^\n\S]+# Call the method with a truthy value for each flattened field,
+        [^\n\S]+# using the keyword arguments to the method\.)
+        \s+response = (await client\.pull\(.*?\))"""
+        ),
+        """\n\g<1>
+        with warnings.catch_warnings():
+            warnings.simplefilter("ignore", category=DeprecationWarning)
+            \g<2>""",
+        flags=re.MULTILINE | re.DOTALL,
+    )
+
+    if count < 1:
+        raise Exception("Catch warnings replacement failed.")
+
+    # Make sure that client library version is present in user agent header.
+    count = s.replace(
+        [
+            library
+            / f"google/pubsub_{library.name}/services/publisher/async_client.py",
+            library / f"google/pubsub_{library.name}/services/publisher/client.py",
+            library
+            / f"google/pubsub_{library.name}/services/publisher/transports/base.py",
+            library
+            / f"google/pubsub_{library.name}/services/schema_service/async_client.py",
+            library / f"google/pubsub_{library.name}/services/schema_service/client.py",
+            library
+            / f"google/pubsub_{library.name}/services/schema_service/transports/base.py",
+            library
+            / f"google/pubsub_{library.name}/services/subscriber/async_client.py",
+            library / f"google/pubsub_{library.name}/services/subscriber/client.py",
+            library
+            / f"google/pubsub_{library.name}/services/subscriber/transports/base.py",
+        ],
+        r"""gapic_version=package_version.__version__""",
+        "client_library_version=package_version.__version__",
+    )
+
+    if count < 1:
+        raise Exception("client_library_version replacement failed.")
+
+    # Allow timeout to be an instance of google.api_core.timeout.*
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/types/__init__.py",
+        r"from \.pubsub import \(",
+        "from typing import Union\n\n\g<0>",
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 1 failed.")
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/types/__init__.py",
+        r"__all__ = \(\n",
+        textwrap.dedent(
+            '''\
+            TimeoutType = Union[
+                int,
+                float,
+                "google.api_core.timeout.ConstantTimeout",
+                "google.api_core.timeout.ExponentialTimeout",
+            ]
+            """The type of the timeout parameter of publisher client methods."""
+
+            \g<0>    "TimeoutType",'''
+        ),
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 2 failed.")
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/publisher/*client.py",
+        r"from google.api_core import retry as retries.*\n",
+        "\g<0>from google.api_core import timeout as timeouts  # type: ignore\n",
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 3 failed.")
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/publisher/*client.py",
+        f"from google\.pubsub_{library.name}\.types import pubsub",
+        f"\g<0>\nfrom google.pubsub_{library.name}.types import TimeoutType",
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 4 failed.")
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/publisher/*client.py",
+        r"(\s+)timeout: Union\[float, object\] = gapic_v1.method.DEFAULT.*\n",
+        f"\g<1>timeout: TimeoutType = gapic_{library.name}.method.DEFAULT,",
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 5 failed.")
+
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/publisher/*client.py",
+        r"([^\S\r\n]+)timeout \(float\): (.*)\n",
+        ("\g<1>timeout (TimeoutType):\n" "\g<1>    \g<2>\n"),
+    )
+
+    if count < 1:
+        raise Exception("Catch timeout replacement 6 failed.")
+
+    # Override the default max retry deadline for publisher methods.
+    count = s.replace(
+        library / f"google/pubsub_{library.name}/services/publisher/transports/base.py",
+        r"deadline=60\.0",
+        "deadline=600.0",
+    )
+    if count < 9:
+        raise Exception(
+            "Default retry deadline not overriden for all publisher methods."
+        )
+
+    # The namespace package declaration in google/cloud/__init__.py should be excluded
+    # from coverage.
+    count = s.replace(
+        library / ".coveragerc",
+        "google/pubsub/__init__.py",
+        """google/cloud/__init__.py
+    google/pubsub/__init__.py""",
+    )
+
+    if count < 1:
+        raise Exception(".coveragerc replacement failed.")
+
+    s.move([library], excludes=["**/gapic_version.py", "noxfile.py", "README.rst", "docs/**/*", "setup.py", "testing/constraints-3.7.txt", "testing/constraints-3.8.txt"])
+s.remove_staging_dirs()
+
+# ----------------------------------------------------------------------------
+# Add templated files
+# ----------------------------------------------------------------------------
+
+templated_files = gcp.CommonTemplates().py_library(
+    microgenerator=True,
+    samples=True,
+    cov_level=99,
+    versions=gcp.common.detect_versions(path="./google", default_first=True),
+    unit_test_python_versions=["3.7", "3.8", "3.9", "3.10", "3.11", "3.12", "3.13", "3.14"],
+    unit_test_dependencies=["flaky"],
+    system_test_python_versions=["3.12"],
+    system_test_external_dependencies=["psutil","flaky"],
+)
+s.move(templated_files, excludes=[".coveragerc", ".github/**", "README.rst", "docs/**", ".kokoro/**"])
+
+python.py_samples(skip_readmes=True)
+
+# run format session for all directories which have a noxfile
+for noxfile in Path(".").glob("**/noxfile.py"):
+    s.shell.run(["nox", "-s", "blacken"], cwd=noxfile.parent, hide_output=False)
diff --git a/.librarian/generator-input/setup.py b/.librarian/generator-input/setup.py
new file mode 100644
index 000000000..6dbea105a
--- /dev/null
+++ b/.librarian/generator-input/setup.py
@@ -0,0 +1,104 @@
+# -*- coding: utf-8 -*-
+# Copyright 2022 Google LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+#
+import io
+import os
+
+import setuptools  # type: ignore
+
+package_root = os.path.abspath(os.path.dirname(__file__))
+
+name = "google-cloud-pubsub"
+
+
+description = "Google Cloud Pub/Sub API client library"
+
+version = {}
+with open(os.path.join(package_root, "google/pubsub/gapic_version.py")) as fp:
+    exec(fp.read(), version)
+version = version["__version__"]
+
+if version[0] == "0":
+    release_status = "Development Status :: 4 - Beta"
+else:
+    release_status = "Development Status :: 5 - Production/Stable"
+
+dependencies = [
+    "grpcio >= 1.51.3, < 2.0.0; python_version < '3.14'",  # https://github.com/googleapis/python-pubsub/issues/609
+    "grpcio >= 1.75.1, < 2.0.0; python_version >= '3.14'",
+    # google-api-core >= 1.34.0 is allowed in order to support google-api-core 1.x
+    "google-auth >= 2.14.1, <3.0.0",
+    "google-api-core[grpc] >= 1.34.0, <3.0.0,!=2.0.*,!=2.1.*,!=2.2.*,!=2.3.*,!=2.4.*,!=2.5.*,!=2.6.*,!=2.7.*,!=2.8.*,!=2.9.*,!=2.10.*",
+    "proto-plus >= 1.22.0, <2.0.0",
+    "proto-plus >= 1.22.2, <2.0.0; python_version>='3.11'",
+    "proto-plus >= 1.25.0, < 2.0.0; python_version >= '3.13'",
+    "protobuf>=3.20.2,<7.0.0,!=4.21.0,!=4.21.1,!=4.21.2,!=4.21.3,!=4.21.4,!=4.21.5",
+    "grpc-google-iam-v1 >= 0.12.4, < 1.0.0",
+    "grpcio-status >= 1.33.2",
+    "opentelemetry-api <= 1.22.0; python_version<='3.7'",
+    "opentelemetry-api >= 1.27.0; python_version>='3.8'",
+    "opentelemetry-sdk <= 1.22.0; python_version<='3.7'",
+    "opentelemetry-sdk >= 1.27.0; python_version>='3.8'",
+]
+extras = {"libcst": "libcst >= 0.3.10"}
+url = "https://github.com/googleapis/python-pubsub"
+
+package_root = os.path.abspath(os.path.dirname(__file__))
+
+readme_filename = os.path.join(package_root, "README.rst")
+with io.open(readme_filename, encoding="utf-8") as readme_file:
+    readme = readme_file.read()
+
+packages = [
+    package
+    for package in setuptools.find_namespace_packages()
+    if package.startswith("google")
+]
+
+setuptools.setup(
+    name=name,
+    version=version,
+    description=description,
+    long_description=readme,
+    author="Google LLC",
+    author_email="googleapis-packages@google.com",
+    license="Apache 2.0",
+    url=url,
+    classifiers=[
+        release_status,
+        "Intended Audience :: Developers",
+        "License :: OSI Approved :: Apache Software License",
+        "Programming Language :: Python",
+        "Programming Language :: Python :: 3",
+        "Programming Language :: Python :: 3.7",
+        "Programming Language :: Python :: 3.8",
+        "Programming Language :: Python :: 3.9",
+        "Programming Language :: Python :: 3.10",
+        "Programming Language :: Python :: 3.11",
+        "Programming Language :: Python :: 3.12",
+        "Programming Language :: Python :: 3.13",
+        "Programming Language :: Python :: 3.14",
+        "Operating System :: OS Independent",
+        "Topic :: Internet",
+    ],
+    platforms="Posix; MacOS X; Windows",
+    packages=packages,
+    install_requires=dependencies,
+    extras_require=extras,
+    python_requires=">=3.7",
+    scripts=["scripts/fixup_pubsub_v1_keywords.py"],
+    include_package_data=True,
+    zip_safe=False,
+)
diff --git a/.librarian/state.yaml b/.librarian/state.yaml
index deaa22de7..03c0cc990 100644
--- a/.librarian/state.yaml
+++ b/.librarian/state.yaml
@@ -2,9 +2,19 @@ image: us-central1-docker.pkg.dev/cloud-sdk-librarian-prod/images-prod/python-li
 libraries:
   - id: google-cloud-pubsub
     version: 2.31.1
-    apis: []
+    last_generated_commit: d300b151a973ce0425ae4ad07b3de957ca31bec6
+    apis:
+      - path: google/pubsub/v1
+        service_config: pubsub_v1.yaml
     source_roots:
       - .
-    preserve_regex: []
-    remove_regex: []
+    preserve_regex:
+      - .git
+      - CHANGELOG.md
+      - docs/CHANGELOG.md
+      - docs/README.rst
+      - tests/system
+      - google/cloud/pubsub
+    remove_regex:
+      - .
     tag_format: v{version}