Fix typing

Author: NoahStapp

pymongo/asynchronous/change_stream.py

@@ -258,7 +258,8 @@ async def _run_aggregation_cmd(
 
     async def _create_cursor(self) -> AsyncCommandCursor:  # type: ignore[type-arg]
         async with self._client._tmp_session(self._session) as s:
-            s.leave_alive = True
+            if s:
+                s.leave_alive = True
             return await self._run_aggregation_cmd(session=s)
 
     async def _resume(self) -> None:

pymongo/asynchronous/command_cursor.py

@@ -197,7 +197,7 @@ def session(self) -> Optional[AsyncClientSession]:
 
         .. versionadded:: 3.6
         """
-        if not self._session.implicit:
+        if self._session and not self._session.implicit:
             return self._session
         return None
 

pymongo/asynchronous/database.py

@@ -611,7 +611,8 @@ async def create_collection(
             common.validate_is_mapping("clusteredIndex", clustered_index)
 
         async with self._client._tmp_session(session) as s:
-            s.leave_alive = True
+            if s:
+                s.leave_alive = True
             # Skip this check in a transaction where listCollections is not
             # supported.
             if (

pymongo/synchronous/change_stream.py

@@ -256,7 +256,8 @@ def _run_aggregation_cmd(self, session: Optional[ClientSession]) -> CommandCurso
 
     def _create_cursor(self) -> CommandCursor:  # type: ignore[type-arg]
         with self._client._tmp_session(self._session) as s:
-            s.leave_alive = True
+            if s:
+                s.leave_alive = True
             return self._run_aggregation_cmd(session=s)
 
     def _resume(self) -> None:

pymongo/synchronous/command_cursor.py

@@ -197,7 +197,7 @@ def session(self) -> Optional[ClientSession]:
 
         .. versionadded:: 3.6
         """
-        if not self._session.implicit:
+        if self._session and not self._session.implicit:
             return self._session
         return None
 

pymongo/synchronous/database.py

@@ -611,7 +611,8 @@ def create_collection(
             common.validate_is_mapping("clusteredIndex", clustered_index)
 
         with self._client._tmp_session(session) as s:
-            s.leave_alive = True
+            if s:
+                s.leave_alive = True
             # Skip this check in a transaction where listCollections is not
             # supported.
             if (