162:ee031ea48eb0
Anton Shestakov <av6@dwimlabs.net>, Tue, 31 Oct 2017 13:23:11 +0800
pipelines: give it one minute

previous change 104:28caf44e903a

fruitbar/indexes.py

Permissions: -rw-r--r--

Other formats: Feeds:
from hashlib import md5
from CodernityDB.hash_index import HashIndex
class ProjectIndex(HashIndex):
def __init__(self, *args, **kwargs):
kwargs['key_format'] = '16s'
super(ProjectIndex, self).__init__(*args, **kwargs)
def make_key_value(self, data):
if data['_t'] == 'project':
return md5(data['workspace'].encode('utf-8')).digest(), None
def make_key(self, key):
return md5(key).digest()
class TaskIndex(HashIndex):
def __init__(self, *args, **kwargs):
kwargs['key_format'] = '16s'
super(TaskIndex, self).__init__(*args, **kwargs)
def make_key_value(self, data):
if data['_t'] == 'task':
return md5(data['workspace'].encode('utf-8')).digest(), None
def make_key(self, key):
return md5(key).digest()
def run_delete_for_project(self, db, workspace, project_id):
for task in db.get_many('task', workspace, with_doc=True):
if task['doc']['project_id'] == project_id:
db.delete(task['doc'])