diff --git a/src/intersect_sdk/_internal/control_plane/brokers/amqp_client.py b/src/intersect_sdk/_internal/control_plane/brokers/amqp_client.py
index ef04b0b..ad34bc1 100644
--- a/src/intersect_sdk/_internal/control_plane/brokers/amqp_client.py
+++ b/src/intersect_sdk/_internal/control_plane/brokers/amqp_client.py
@@ -254,7 +254,7 @@ def _on_connection_closed(self, connection: pika.SelectConnection, reason: Excep
         if self._should_disconnect:
             connection.ioloop.stop()
         else:
-            logger.warn('Connection closed, reopening in 5 seconds: %s', reason)
+            logger.warning('Connection closed, reopening in 5 seconds: %s', reason)
             connection.ioloop.call_later(5, connection.ioloop.stop)
         self._channel_flags.unset_all()
         self._channel_out = None
diff --git a/src/intersect_sdk/_internal/data_plane/data_plane_manager.py b/src/intersect_sdk/_internal/data_plane/data_plane_manager.py
index 3051fbd..83285e3 100644
--- a/src/intersect_sdk/_internal/data_plane/data_plane_manager.py
+++ b/src/intersect_sdk/_internal/data_plane/data_plane_manager.py
@@ -32,7 +32,7 @@ def __init__(self, hierarchy: HierarchyConfig, data_configs: DataStoreConfigMap)
 
         # warn users about missing data plane
         if not self._minio_providers:
-            logger.warn('WARNING: This service cannot support any MINIO instances')
+            logger.warning('WARNING: This service cannot support any MINIO instances')
 
     def incoming_message_data_handler(self, message: UserspaceMessage | EventMessage) -> bytes:
         """Get data from the request data provider.