checkpoint

Author: aucampia

rdflib/events.py

@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 __doc__ = """
 Dirt Simple Events
 
@@ -23,6 +25,12 @@
   <rdflib.events.Event ['data', 'foo', 'used_by']>
 """
 
+
+from typing import TYPE_CHECKING, Any, Dict, Optional
+
+if TYPE_CHECKING:
+    import typing_extensions as te
+
 __all__ = ["Event", "Dispatcher"]
 
 
@@ -53,9 +61,9 @@ class Dispatcher:
     subscribers.
     """
 
-    _dispatch_map = None
+    _dispatch_map: Optional[Dict[Any, Any]] = None
 
-    def set_map(self, amap):
+    def set_map(self, amap: Dict[Any, Any]) -> te.Self:
         self._dispatch_map = amap
         return self
 

rdflib/plugins/parsers/notation3.py

@@ -276,7 +276,7 @@ def _fixslash(s: str) -> str:
 N3_Empty = (SYMBOL, List_NS + "Empty")
 
 
-runNamespaceValue = None
+runNamespaceValue: Optional[str] = None
 
 
 def runNamespace() -> str:

rdflib/plugins/sparql/parserutils.py

@@ -14,7 +14,7 @@
     Union,
 )
 
-from pyparsing import ParseResults, TokenConverter, originalTextFor
+from pyparsing import ParseResults, ParserElement, TokenConverter, originalTextFor
 
 from rdflib.term import BNode, Identifier, Variable
 
@@ -241,7 +241,7 @@ class Comp(TokenConverter):
     Returns CompValue / Expr objects - depending on whether evalFn is set.
     """
 
-    def __init__(self, name: str, expr):
+    def __init__(self, name: str, expr: ParserElement):
         self.expr = expr
         TokenConverter.__init__(self, expr)
         self.setName(name)

rdflib/plugins/stores/memory.py

@@ -34,7 +34,7 @@
 
 __all__ = ["SimpleMemory", "Memory"]
 
-ANY = None
+ANY: None = None
 
 
 class SimpleMemory(Store):

rdflib/store.py

@@ -65,7 +65,7 @@
 VALID_STORE = 1
 CORRUPTED_STORE = 0
 NO_STORE = -1
-UNKNOWN = None
+UNKNOWN: None = None
 
 
 Pickler = pickle.Pickler

rdflib/tools/csv2rdf.py

@@ -16,12 +16,15 @@
 import re
 import sys
 import time
+from typing import Any, Dict, List, Optional, Tuple
 import warnings
 from urllib.parse import quote
 
 import rdflib
 from rdflib.namespace import RDF, RDFS, split_uri
 
+from rdflib.term import URIRef
+
 __all__ = ["CSV2RDF"]
 
 HELP = """
@@ -87,7 +90,7 @@
 """
 
 # bah - ugly global
-uris = {}
+uris: Dict[Any, Tuple[URIRef, Optional[URIRef]]] = {}
 
 
 def toProperty(label):
@@ -112,7 +115,7 @@ def toPropertyLabel(label):
     return label
 
 
-def index(l_, i):
+def index(l_: List[int], i: Tuple[int, ...]) -> Tuple[int, ...]:
     """return a set of indexes from a list
     >>> index([1,2,3],(0,2))
     (1, 3)
@@ -126,7 +129,7 @@ def csv_reader(csv_data, dialect=csv.excel, **kwargs):
         yield row
 
 
-def prefixuri(x, prefix, class_=None):
+def prefixuri(x, prefix, class_: Optional[URIRef] = None):
     if prefix:
         r = rdflib.URIRef(prefix + quote(x.encode("utf8").replace(" ", "_"), safe=""))
     else:
@@ -142,7 +145,7 @@ class NodeMaker:
     def range(self):
         return rdflib.RDFS.Literal
 
-    def __call__(self, x):
+    def __call__(self, x: Any):
         return rdflib.Literal(x)
 
 

test/jsonld/test_compaction.py

@@ -3,6 +3,7 @@
 import itertools
 import json
 import re
+from typing import Any, Dict, List, Tuple
 
 import pytest
 
@@ -13,11 +14,11 @@
 register("json-ld", Serializer, "rdflib.plugins.serializers.jsonld", "JsonLDSerializer")
 
 
-cases = []
+cases: List[Tuple[str, Dict[str, Any]]] = []
 
 
-def case(*args):
-    cases.append(args)
+def case(source:str, data: Dict[str, Any]):
+    cases.append((source, data))
 
 
 case(

test/test_graph/test_graph_context.py

@@ -1,6 +1,7 @@
 import os
 import shutil
 import sys
+from typing import Optional
 import unittest
 from tempfile import mkdtemp, mkstemp
 
@@ -13,7 +14,7 @@
 class ContextTestCase(unittest.TestCase):
     store = "default"
     slow = True
-    tmppath = None
+    tmppath: Optional[str] = None
 
     def setUp(self):
         try:

test/test_sparql/test_prefixed_name.py

@@ -1,11 +1,10 @@
 import itertools
 import logging
 from contextlib import ExitStack
-from typing import Type, Union
+from typing import Type, Union, Optional
 
 import pyparsing
 import pytest
-from pyparsing import Optional
 
 import rdflib
 from rdflib import Graph

test/utils/sparql_checker.py

@@ -300,11 +300,11 @@ def check_syntax(monkeypatch: MonkeyPatch, entry: SPARQLEntry) -> None:
         if entry.type_info.negative:
             catcher = xstack.enter_context(pytest.raises(Exception))
         if entry.type_info.query_type is QueryType.UPDATE:
-            tree = parseUpdate(query_text)
-            translateUpdate(tree)
+            parseTree = parseUpdate(query_text)
+            translateUpdate(parseTree)
         elif entry.type_info.query_type is QueryType.QUERY:
-            tree = parseQuery(query_text)
-            translateQuery(tree)
+            queryTree = parseQuery(query_text)
+            translateQuery(queryTree)
     if catcher is not None:
         assert catcher.value is not None
         logging.info("catcher.value = %s", catcher.value)