11import queue
2- from typing import Any
2+ from typing import Any , Optional
33
44from .errors import ProgrammingError , DatabaseError
55
@@ -11,20 +11,20 @@ def __init__(self, exec_fn, cancel_fn):
1111 self .__cancel_fn = cancel_fn
1212
1313 self .__queue : queue .Queue = queue .Queue ()
14- self .__results : list [Any ] | None = None
15- self .__current_execution_id : str | None = None
14+ self .__results : Optional [ list [Any ]] = None
15+ self .__current_execution_id : Optional [ str ] = None
1616 self .__current_row : int = 0
1717
1818 # Description and row count are set by the last executed operation.
1919 # Their default values are defined by PEP-0249.
20- self .__description : str | None = None
20+ self .__description : Optional [ str ] = None
2121 self .__rowcount : int = - 1
2222
2323 # Array-size is also defined by PEP-0249 and is expected to be read/writable.
2424 self .arraysize : int = 1
2525
2626 @property
27- def description (self ) -> str | None :
27+ def description (self ) -> Optional [ str ] :
2828 return self .__description
2929
3030 @property
@@ -34,7 +34,7 @@ def rowcount(self) -> int:
3434 def __on_execution_result (self , result ) -> None :
3535 self .__queue .put (result )
3636
37- def __get_results (self ) -> list [Any ] | None :
37+ def __get_results (self ) -> Optional [ list [Any ]] :
3838 if not self .__current_execution_id :
3939 raise ProgrammingError ("No query has been executed yet" )
4040 if self .__results is not None :
0 commit comments