diff --git a/samples/samples/snippets.py b/samples/samples/snippets.py
index f55e456bec..92fdd99132 100644
--- a/samples/samples/snippets.py
+++ b/samples/samples/snippets.py
@@ -2540,6 +2540,32 @@ def read_then_write(transaction):
     # [END spanner_transaction_timeout]
 
 
+def set_statement_timeout(instance_id, database_id):
+    """Executes a transaction with a statement timeout."""
+    # [START spanner_set_statement_timeout]
+    # instance_id = "your-spanner-instance"
+    # database_id = "your-spanner-db-id"
+    spanner_client = spanner.Client()
+    instance = spanner_client.instance(instance_id)
+    database = instance.database(database_id)
+
+    def write(transaction):
+        # Insert a record and configure the statement timeout to 60 seconds
+        # This timeout can however ONLY BE SHORTER than the default timeout
+        # for the RPC. If you set a timeout that is longer than the default timeout,
+        # then the default timeout will be used.
+        row_ct = transaction.execute_update(
+            "INSERT INTO Singers (SingerId, FirstName, LastName) "
+            " VALUES (110, 'George', 'Washington')",
+            timeout=60,
+        )
+        print("{} record(s) inserted.".format(row_ct))
+
+    database.run_in_transaction(write)
+
+    # [END spanner_set_statement_timeout]
+
+
 def set_request_tag(instance_id, database_id):
     """Executes a snapshot read with a request tag."""
     # [START spanner_set_request_tag]
@@ -3651,6 +3677,7 @@ def add_split_points(instance_id, database_id):
     subparsers.add_parser(
         "set_transaction_timeout", help=set_transaction_timeout.__doc__
     )
+    subparsers.add_parser("set_statement_timeout", help=set_statement_timeout.__doc__)
     subparsers.add_parser(
         "query_data_with_new_column", help=query_data_with_new_column.__doc__
     )
@@ -3819,6 +3846,8 @@ def add_split_points(instance_id, database_id):
         set_max_commit_delay(args.instance_id, args.database_id)
     elif args.command == "set_transaction_timeout":
         set_transaction_timeout(args.instance_id, args.database_id)
+    elif args.command == "set_statement_timeout":
+        set_statement_timeout(args.instance_id, args.database_id)
     elif args.command == "query_data_with_new_column":
         query_data_with_new_column(args.instance_id, args.database_id)
     elif args.command == "read_write_transaction":
diff --git a/samples/samples/snippets_test.py b/samples/samples/snippets_test.py
index 3fcd16755c..01482518db 100644
--- a/samples/samples/snippets_test.py
+++ b/samples/samples/snippets_test.py
@@ -862,6 +862,13 @@ def test_set_transaction_timeout(capsys, instance_id, sample_database):
     assert "1 record(s) inserted." in out
 
 
+@pytest.mark.dependency(depends=["insert_datatypes_data"])
+def test_set_statement_timeout(capsys, instance_id, sample_database):
+    snippets.set_statement_timeout(instance_id, sample_database.database_id)
+    out, _ = capsys.readouterr()
+    assert "1 record(s) inserted." in out
+
+
 @pytest.mark.dependency(depends=["insert_data"])
 def test_set_request_tag(capsys, instance_id, sample_database):
     snippets.set_request_tag(instance_id, sample_database.database_id)