Skip license-gated pull-replication tests on CI; quiet noisy test output

- Gate the 8 commercial pull-replication tests behind the repo-standard
  @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, ...) so they skip on
  fork CI (no secret) instead of failing; client-side and JSON round-trip tests still run.
- In TestBase.setUp, silence subscription-worker ERROR logs and datetime.utcnow
  DeprecationWarnings (set inside setUp so the filter survives unittest per-run reset).

Author: poissoncorp

ravendb/tests/jvm_migrated_tests/client_tests/replication_tests/test_pull_replication.py

@@ -1,4 +1,6 @@
 import base64
+import os
+import unittest
 from datetime import timedelta
 
 from ravendb import (
@@ -49,14 +51,17 @@ def _put_connection_string(self, name, database):
         self.store.maintenance.send(PutConnectionStringOperation(connection_string))
         return name
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_can_put_pull_replication_as_hub(self):
         result = self._put_hub("hub-1")
         self.assertGreater(result.task_id, 0)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_can_put_pull_replication_as_hub_by_name(self):
         result = self.store.maintenance.send(PutPullReplicationAsHubOperation(name="hub-by-name"))
         self.assertIsNotNone(result.task_id)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_can_get_pull_replication_tasks_info(self):
         result = self._put_hub("hub-info", delay_replication_for=timedelta(seconds=30))
 
@@ -68,6 +73,7 @@ def test_can_get_pull_replication_tasks_info(self):
         self.assertEqual(timedelta(seconds=30), info.definition.delay_replication_for)
         self.assertIsNotNone(info.ongoing_tasks)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_can_update_pull_replication_as_sink(self):
         connection_string_name = self._put_connection_string("cs-sink", "sink-remote-db")
         sink = PullReplicationAsSink(
@@ -88,6 +94,7 @@ def test_can_update_pull_replication_as_sink(self):
         self.assertEqual("remote-hub", info.hub_name)
         self.assertEqual("my-sink", info.task_name)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_can_update_external_replication(self):
         connection_string_name = self._put_connection_string("cs-ext", "external-remote-db")
         external = ExternalReplication(
@@ -100,11 +107,13 @@ def test_can_update_external_replication(self):
         self.assertIsNotNone(result)
         self.assertIsNotNone(result.task_id)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_get_replication_hub_access_is_empty_for_new_hub(self):
         self._put_hub("hub-no-access")
         access = self.store.maintenance.send(GetReplicationHubAccessOperation("hub-no-access"))
         self.assertEqual([], access)
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_register_replication_hub_access_for_missing_hub_raises(self):
         access = ReplicationHubAccess(name="sink-1", certificate_base64=_DUMMY_CERTIFICATE_B64)
         operation = RegisterReplicationHubAccessOperation("hub-that-does-not-exist", access)
@@ -119,6 +128,7 @@ def test_register_replication_hub_access_for_missing_hub_raises(self):
         except RavenException as e:
             self.assertIn("hub-that-does-not-exist", str(e))
 
+    @unittest.skipIf(os.environ.get("RAVENDB_LICENSE") is None, "Insufficient license permissions. Skipping on CI/CD.")
     def test_unregister_replication_hub_access_is_noop_for_unknown_thumbprint(self):
         self._put_hub("hub-unregister")
         # Removing an unknown thumbprint from an existing hub must not raise.

ravendb/tests/test_base.py

@@ -1,10 +1,12 @@
 import atexit
 import datetime
+import logging
 import threading
 import time
 import unittest
 import sys
 import os
+import warnings
 from enum import Enum
 from typing import Iterable, List, Optional, Set
 from datetime import timedelta
@@ -402,6 +404,12 @@ def setConvention(self, conventions):
         self.conventions = conventions
 
     def setUp(self):
+        # Keep test output readable: silence noisy background-thread logs (e.g. the
+        # subscription worker reporting expected connection drops on teardown) and the
+        # datetime.utcnow deprecation warnings emitted across the client. Set here, inside
+        # the run, so the warning filter survives unittest's per-run "default" reset.
+        logging.disable(logging.ERROR)
+        warnings.filterwarnings("ignore", category=DeprecationWarning)
         RavenTestDriver.__init__(self)
         self._locator = TestBase.TestServiceLocator()
         self._secured_locator = TestBase.TestSecuredServiceLocator()