pro-barbu-foss/kheops
pro-barbu-foss/kheops
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Lint: query.py

Browse Source
This commit is contained in:
mrjk 2022-01-26 15:46:46 -05:00
parent c97c171f41
commit 0af7ba8598
1 changed files with 12 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
kheops/query.py
View File

@ -1,22 +1,9 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
"""Kheops Query Class"""
# import sys
# sys.path.append("/home/jez/prj/bell/training/tiger-ansible/ext/ansible-tree")
import sys
import yaml
import anyconfig
from pprint import pprint
from kheops.managers import BackendsManager, RulesManager
from kheops.utils import schema_validate
import anyconfig
# from box import Box
from pathlib import Path
import logging import logging
from pprint import pprint
from kheops.managers import BackendsManager, RulesManager
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
@ -26,21 +13,25 @@ log = logging.getLogger(__name__)
class Query: class Query:
"""Kheops Query Class"""
def __init__(self, app): def __init__(self, app):
self.app = app self.app = app
def exec(self, key=None, scope=None, policy=None, trace=False, explain=False): def exec(self, key=None, scope=None, policy=None, trace=False, explain=False):
"""Execute the query"""
bm = BackendsManager(app=self.app) bmgr = BackendsManager(app=self.app)
mm = RulesManager(app=self.app) mmgr = RulesManager(app=self.app)
log.debug(f"New query created") log.debug("New query created")
candidates = bm.query(key, scope, trace=trace) candidates = bmgr.query(key, scope, trace=trace)
result = mm.get_result(candidates, key=key, trace=trace, explain=explain) result = mmgr.get_result(candidates, key=key, trace=trace, explain=explain)
return result return result
def dump(self): def dump(self):
"""Dump the query object"""
ret = {} ret = {}
for i in dir(self): for i in dir(self):