Address PR comments for Python examples integration

- Add explanatory comments for Docker port configurations
- Use specialized labels (person-py-ex, py-conn-ex) to isolate test data
- Replace global cleanup with targeted cleanup using has_label()
- Add conditional SSL certificate verification for non-localhost connections
- Fix Kerberos hostname to match conftest.py approach

Author: kirill-stepanishin

gremlin-python/src/main/python/examples/basic_gremlin.py

@@ -26,34 +26,32 @@
 
 
 def main():
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_URL', 'ws://localhost:8182/gremlin').format(45940)
     rc = DriverRemoteConnection(server_url, 'g')
     g = traversal().with_remote(rc)
 
-    # drop existing vertices
-    g.V().drop().iterate()
-
     # basic Gremlin: adding and retrieving data
-    v1 = g.add_v('person').property('name', 'marko').next()
-    v2 = g.add_v('person').property('name', 'stephen').next()
-    v3 = g.add_v('person').property('name', 'vadas').next()
+    v1 = g.add_v('person-py-ex').property('name', 'marko').next()
+    v2 = g.add_v('person-py-ex').property('name', 'stephen').next()
+    v3 = g.add_v('person-py-ex').property('name', 'vadas').next()
 
     # be sure to use a terminating step like next() or iterate() so that the traversal "executes"
     # iterate() does not return any data and is used to just generate side-effects (i.e. write data to the database)
     g.V(v1).add_e('knows').to(v2).property('weight', 0.75).iterate()
     g.V(v1).add_e('knows').to(v3).property('weight', 0.75).iterate()
 
     # retrieve the data from the "marko" vertex
-    marko = g.V().has('person', 'name', 'marko').values('name').next()
+    marko = g.V().has('person-py-ex', 'name', 'marko').values('name').next()
     print("name: " + marko)
 
     # find the "marko" vertex and then traverse to the people he "knows" and return their data
-    people_marko_knows = g.V().has('person', 'name', 'marko').out('knows').values('name').to_list()
+    people_marko_knows = g.V().has('person-py-ex', 'name', 'marko').out('knows').values('name').to_list()
     for person in people_marko_knows:
         print("marko knows " + person)
 
     # clean added data
-    g.V().drop().iterate()
+    g.V().has_label('person-py-ex').drop().iterate()
 
     rc.close()
 

gremlin-python/src/main/python/examples/connections.py

@@ -18,6 +18,7 @@
 import sys
 import os
 import ssl
+import socket
 
 sys.path.append("..")
 
@@ -43,72 +44,70 @@ def with_remote():
     #
     # which starts it in "console" mode with an empty in-memory TinkerGraph ready to go bound to a
     # variable named "g" as referenced in the following line.
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_URL', 'ws://localhost:8182/gremlin').format(45940)
     rc = DriverRemoteConnection(server_url, 'g')
     g = traversal().with_remote(rc)
 
-    # drop existing vertices
-    g.V().drop().iterate()
-
     # simple query to verify connection
-    v = g.add_v().iterate()
-    count = g.V().count().next()
+    v = g.add_v('py-conn-ex').iterate()
+    count = g.V().has_label('py-conn-ex').count().next()
     print("Vertex count: " + str(count))
 
+    # clean added data
+    g.V().has_label('py-conn-ex').drop().iterate()
     # cleanup
     rc.close()
 
 
 # connecting with plain text authentication
 def with_auth():
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_BASIC_AUTH_URL', 'ws://localhost:8182/gremlin').format(45941)
-    # turn off certificate verification for testing purposes only
-    ssl_opts = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
-    ssl_opts.check_hostname = False
-    ssl_opts.verify_mode = ssl.CERT_NONE
-    rc = DriverRemoteConnection(server_url, 'g', username='stephen', password='password',
-                                transport_factory=lambda: AiohttpTransport(ssl_options=ssl_opts))
+    
+    # disable SSL certificate verification for remote hosts in test environments
+    if 'localhost' not in server_url:
+        ssl_opts = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
+        ssl_opts.check_hostname = False
+        ssl_opts.verify_mode = ssl.CERT_NONE
+        rc = DriverRemoteConnection(server_url, 'g', username='stephen', password='password',
+                                    transport_factory=lambda: AiohttpTransport(ssl_options=ssl_opts))
+    else:
+        rc = DriverRemoteConnection(server_url, 'g', username='stephen', password='password')
+    
     g = traversal().with_remote(rc)
 
-    # drop existing vertices
-    g.V().drop().iterate()
-
-    v = g.add_v().iterate()
-    count = g.V().count().next()
+    v = g.add_v('py-conn-ex').iterate()
+    count = g.V().has_label('py-conn-ex').count().next()
     print("Vertex count: " + str(count))
 
     # clean added data
-    g.V().drop().iterate()
+    g.V().has_label('py-conn-ex').drop().iterate()
     rc.close()
 
 
 # connecting with Kerberos SASL authentication
 def with_kerberos():
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_URL', 'ws://localhost:8182/gremlin').format(45942)
-    kerberos_hostname = os.getenv('KRB_HOSTNAME', 'gremlin-server-test')
+    kerberos_hostname = os.getenv('KRB_HOSTNAME', socket.gethostname())
     kerberized_service = f'test-service@{kerberos_hostname}'
 
-    try:
-        rc = DriverRemoteConnection(server_url, 'g', kerberized_service=kerberized_service)
-        g = traversal().with_remote(rc)
-
-        # drop existing vertices
-        g.V().drop().iterate()
+    rc = DriverRemoteConnection(server_url, 'g', kerberized_service=kerberized_service)
+    g = traversal().with_remote(rc)
 
-        v = g.add_v().iterate()
-        count = g.V().count().next()
-        print("Vertex count: " + str(count))
+    v = g.add_v('py-conn-ex').iterate()
+    count = g.V().has_label('py-conn-ex').count().next()
+    print("Vertex count: " + str(count))
 
-        # clean added data
-        g.V().drop().iterate()
-        rc.close()
-    except Exception as e:
-        print(f"Kerberos authentication failed (expected in test environment): {e}")
-        # This is expected to fail in CI without proper Kerberos setup
+    # clean added data
+    g.V().has_label('py-conn-ex').drop().iterate()
+    rc.close()
 
 
 # connecting with customized configurations
 def with_configs():
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_URL', 'ws://localhost:8182/gremlin').format(45940)
     rc = DriverRemoteConnection(
         server_url, 'g',
@@ -119,12 +118,12 @@ def with_configs():
     )
     g = traversal().with_remote(rc)
 
-    v = g.add_v().iterate()
-    count = g.V().count().next()
+    v = g.add_v('py-conn-ex').iterate()
+    count = g.V().has_label('py-conn-ex').count().next()
     print("Vertex count: " + str(count))
 
     # clean added data
-    g.V().drop().iterate()
+    g.V().has_label('py-conn-ex').drop().iterate()
 
     rc.close()
 

gremlin-python/src/main/python/examples/modern_traversals.py

@@ -32,6 +32,7 @@ def main():
     # This example requires the Modern toy graph to be preloaded upon launching the Gremlin server.
     # For details, see https://tinkerpop.apache.org/docs/current/reference/#gremlin-server-docker-image and use
     # conf/gremlin-server-modern.yaml.
+    # if there is a port placeholder in the env var then we are running with docker so set appropriate port 
     server_url = os.getenv('GREMLIN_SERVER_URL', 'ws://localhost:8182/gremlin').format(45940)
 
     # CI uses port 45940 with gmodern binding, local uses 8182 with g binding