test(servicebus): subtract clock skew buffer from updated_since boundary

All four updated_since live tests (sync + async, queue + subscription) now use 'datetime.now(timezone.utc) - timedelta(minutes=1)' as the boundary so client/server clock skew can't push the freshly-sent session past the cutoff and cause flakes.

Author: EldertGrootenboerMS

sdk/servicebus/azure-servicebus/tests/async_tests/test_list_sessions_async.py

@@ -6,7 +6,7 @@
 
 import pytest
 import uuid
-from datetime import datetime, timezone
+from datetime import datetime, timedelta, timezone
 
 from azure.servicebus import ServiceBusMessage
 from azure.servicebus.aio import ServiceBusClient
@@ -102,7 +102,8 @@ async def test_list_queue_sessions_updated_since_async(
             logging_enable=False,
             uamqp_transport=uamqp_transport,
         ) as sb_client:
-            before_send = datetime.now(timezone.utc)
+            # Use a 1-minute buffer to absorb client/server clock skew.
+            before_send = datetime.now(timezone.utc) - timedelta(minutes=1)
 
             session_id = str(uuid.uuid4())
             async with sb_client.get_queue_sender(servicebus_queue.name) as sender:
@@ -199,7 +200,8 @@ async def test_list_subscription_sessions_updated_since_async(
             logging_enable=False,
             uamqp_transport=uamqp_transport,
         ) as sb_client:
-            before_send = datetime.now(timezone.utc)
+            # Use a 1-minute buffer to absorb client/server clock skew.
+            before_send = datetime.now(timezone.utc) - timedelta(minutes=1)
 
             session_id = str(uuid.uuid4())
             async with sb_client.get_topic_sender(servicebus_topic.name) as sender:

sdk/servicebus/azure-servicebus/tests/test_list_sessions.py

@@ -6,7 +6,7 @@
 
 import pytest
 import uuid
-from datetime import datetime, timezone
+from datetime import datetime, timedelta, timezone
 
 from azure.servicebus import (
     ServiceBusClient,
@@ -136,7 +136,8 @@ def test_list_queue_sessions_updated_since(
             logging_enable=False,
             uamqp_transport=uamqp_transport,
         ) as sb_client:
-            before_send = datetime.now(timezone.utc)
+            # Use a 1-minute buffer to absorb client/server clock skew.
+            before_send = datetime.now(timezone.utc) - timedelta(minutes=1)
 
             session_id = str(uuid.uuid4())
             with sb_client.get_queue_sender(servicebus_queue.name) as sender:
@@ -197,7 +198,8 @@ def test_list_subscription_sessions_updated_since(
             logging_enable=False,
             uamqp_transport=uamqp_transport,
         ) as sb_client:
-            before_send = datetime.now(timezone.utc)
+            # Use a 1-minute buffer to absorb client/server clock skew.
+            before_send = datetime.now(timezone.utc) - timedelta(minutes=1)
 
             session_id = str(uuid.uuid4())
             with sb_client.get_topic_sender(servicebus_topic.name) as sender: