diff --git a/das/__init__.py b/das/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/das/atomese2metta/translator.py b/das/atomese2metta/translator.py index 01231e6..ea1a532 100644 --- a/das/atomese2metta/translator.py +++ b/das/atomese2metta/translator.py @@ -1,7 +1,7 @@ import re from abc import ABC from collections.abc import MutableSequence -from typing import Iterable, Sequence, Union, Optional +from typing import Iterable, Optional, Sequence, Union from .collections import OrderedSet diff --git a/das/das.py b/das/das.py index c8c3327..08909d6 100644 --- a/das/das.py +++ b/das/das.py @@ -3,17 +3,17 @@ import os from datetime import datetime +from atomese2metta.translator import AtomType, Expression +from hashing import Hasher +from helpers import (evaluate_hash, get_filesize_mb, get_logger, get_mongodb, + human_time) +from metta_lex import MettaParser from pymongo.collection import Collection from pymongo.database import Database from pymongo.errors import DuplicateKeyError from pymongo.operations import DeleteMany from pymongo.results import InsertOneResult -from atomese2metta.translator import AtomType, Expression -from hashing import Hasher -from helpers import get_mongodb, get_logger, evaluate_hash, get_filesize_mb, human_time -from metta_lex import MettaParser - logger = get_logger() diff --git a/das/das_generate_file.py b/das/das_generate_file.py index 9020a11..0dbe849 100644 --- a/das/das_generate_file.py +++ b/das/das_generate_file.py @@ -1,7 +1,7 @@ -import re import argparse import logging import os +import re import shutil from typing import Iterator, Optional @@ -9,9 +9,8 @@ from couchbase.auth import PasswordAuthenticator from couchbase.cluster import Cluster from couchbase.management.collections import CollectionSpec -from pymongo.collection import Collection - from helpers import get_logger, get_mongodb +from pymongo.collection import Collection from util import AccumulatorClock, Clock, Statistics logger = get_logger() diff --git a/das/das_upload_to_couch_from_file.py b/das/das_upload_to_couch_from_file.py index b2b540f..47443d3 100644 --- a/das/das_upload_to_couch_from_file.py +++ b/das/das_upload_to_couch_from_file.py @@ -7,7 +7,6 @@ from couchbase.auth import PasswordAuthenticator from couchbase.cluster import Cluster from couchbase.management.collections import CollectionSpec - from helpers import get_logger logger = get_logger() diff --git a/das/hashing.py b/das/hashing.py index 5a68301..b24ba51 100644 --- a/das/hashing.py +++ b/das/hashing.py @@ -3,7 +3,7 @@ from operator import itemgetter from typing import Any, Union -from .atomese2metta.translator import AtomType, Expression, MSet +from das.atomese2metta.translator import AtomType, Expression, MSet class Hasher: diff --git a/das/lex.py b/das/lex.py index e7ed121..c06a244 100644 --- a/das/lex.py +++ b/das/lex.py @@ -1,8 +1,7 @@ import argparse -from ply.lex import lex - from helpers import get_logger +from ply.lex import lex logger = get_logger() diff --git a/das/metta_lex.py b/das/metta_lex.py index 79e849a..240f6f6 100644 --- a/das/metta_lex.py +++ b/das/metta_lex.py @@ -1,11 +1,11 @@ import argparse from typing import Any, List, Union -from ply.lex import lex - -from atomese2metta.translator import AtomType, Expression, MSet, UnorderedExpression +from atomese2metta.translator import (AtomType, Expression, MSet, + UnorderedExpression) from hashing import Hasher from helpers import get_logger +from ply.lex import lex logger = get_logger() diff --git a/das/parser.py b/das/parser.py index 05e3b00..25f2cd9 100644 --- a/das/parser.py +++ b/das/parser.py @@ -5,7 +5,7 @@ from atomese2metta.parser import LexParser from atomese2metta.translator import Translator -from helpers import get_logger, get_filesize_mb, human_time +from helpers import get_filesize_mb, get_logger, human_time logger = get_logger() diff --git a/das/pattern_matcher/couch_mongo_db.py b/das/pattern_matcher/couch_mongo_db.py index c9baeca..d0cd88f 100644 --- a/das/pattern_matcher/couch_mongo_db.py +++ b/das/pattern_matcher/couch_mongo_db.py @@ -8,6 +8,7 @@ from couchbase.exceptions import DocumentNotFoundException from pymongo.collection import Collection from pymongo.database import Database + from das.hashing import Hasher from .db_interface import DBInterface diff --git a/das/pattern_matcher/pattern_matcher_test.py b/das/pattern_matcher/pattern_matcher_test.py index e90492c..063ac23 100644 --- a/das/pattern_matcher/pattern_matcher_test.py +++ b/das/pattern_matcher/pattern_matcher_test.py @@ -1,13 +1,13 @@ from copy import deepcopy import pytest -from das.pattern_matcher.stub_db import StubDB from das.pattern_matcher.pattern_matcher import (And, CompatibilityStatus, Link, LogicalExpression, Node, Not, OrderedAssignment, PatternMatchingAnswer, UnorderedAssignment, Variable) +from das.pattern_matcher.stub_db import StubDB def test_basic_matching(): diff --git a/das/query.py b/das/query.py index 556bf38..f453404 100644 --- a/das/query.py +++ b/das/query.py @@ -3,17 +3,16 @@ import os from datetime import datetime +from atomese2metta.translator import AtomType, Expression +from hashing import Hasher +from helpers import get_mongodb +from metta_lex import MettaParser from pymongo.collection import Collection from pymongo.database import Database from pymongo.errors import DuplicateKeyError from pymongo.operations import DeleteMany from pymongo.results import InsertOneResult -from atomese2metta.translator import AtomType, Expression -from hashing import Hasher -from helpers import get_mongodb -from metta_lex import MettaParser - class QueryDas: NODE_COLLS = [ diff --git a/das/research/cache.py b/das/research/cache.py index 6416124..38a5844 100644 --- a/das/research/cache.py +++ b/das/research/cache.py @@ -6,7 +6,7 @@ import couchbase.exceptions from couchbase.bucket import Bucket -from heap import PrioritizedItem, Heap +from das.research.heap import Heap, PrioritizedItem class CacheException(Exception): diff --git a/das/research/das_couch_cached.py b/das/research/das_couch_cached.py index 9b6d931..f27034e 100644 --- a/das/research/das_couch_cached.py +++ b/das/research/das_couch_cached.py @@ -5,12 +5,13 @@ from couchbase.auth import PasswordAuthenticator from couchbase.cluster import Cluster from couchbase.management.collections import CollectionSpec -from helpers import get_logger from pymongo.collection import Collection from pymongo.mongo_client import MongoClient -from util import Clock, Statistics, AccumulatorClock +from util import AccumulatorClock, Clock, Statistics -from cache import CachedCouchbaseClient, CouchbaseClient, DocumentNotFoundException +from das.helpers import get_logger +from das.research.cache import (CachedCouchbaseClient, CouchbaseClient, + DocumentNotFoundException) logger = get_logger() diff --git a/das/unifier.py b/das/unifier.py index 3a9dcf9..2c7b0c5 100644 --- a/das/unifier.py +++ b/das/unifier.py @@ -1,14 +1,14 @@ -from cmath import exp -import os import argparse -from typing import Any, List, Union +import os +from cmath import exp from pprint import pprint +from typing import Any, List, Union -from ply.lex import lex - -from atomese2metta.translator import AtomType, Expression, MSet, UnorderedExpression +from atomese2metta.translator import (AtomType, Expression, MSet, + UnorderedExpression) from hashing import Hasher from helpers import get_mongodb +from ply.lex import lex class DAS: diff --git a/das/util.py b/das/util.py index d10a55c..55a35c6 100644 --- a/das/util.py +++ b/das/util.py @@ -3,7 +3,6 @@ import numpy as np import pytest - from helpers import get_logger logger = get_logger() diff --git a/tests/test_parser.py b/tests/test_parser.py index c30052d..0004a0e 100644 --- a/tests/test_parser.py +++ b/tests/test_parser.py @@ -1,4 +1,4 @@ -from scripts.atomese2metta.parser import Parser, MultiprocessingParser, LexParser +from das.atomese2metta.parser import Parser, MultiprocessingParser, LexParser def test_when_split_string_to_two_chunks(): diff --git a/tests/test_translator.py b/tests/test_translator.py index 766250b..4f10629 100644 --- a/tests/test_translator.py +++ b/tests/test_translator.py @@ -1,4 +1,4 @@ -from scripts.atomese2metta.translator import Expression, MList, MSet +from das.atomese2metta.translator import Expression, MList, MSet def test_given_a_expression_instance_then_should_return_a_string_with_parentheses():