mirror of
https://github.com/sartography/cr-connect-workflow.git
synced 2025-02-23 21:28:32 +00:00
2249965ade
Spiffworkflow 1.2: Top Level Imports moved to appropriate modules - replace 'from SpiffWorkflow import WorkflowException' to 'from SpiffWorkflow.exceptions import WorkflowException' - replace 'from SpiffWorkflow import TaskState' to 'from SpiffWorkflow.task import TaskState' - replace 'from SpiffWorkflow import Task' to 'from SpiffWorkflow.task import Task' SpiffWorkflow 1.2: Navigation code removed completely. Proved to be of little use to folks, was super complex and difficult to maintain. SpiffWorkflow 1.2: When inserting custom functions into the PythonExecutionEngine - be aware that the task data will act as the full context for execution, and will contain global functions and methods during the exec call. SpiffWorkflow 1.2: All Task Specs now have a spec_type attribute, containing a descriptive string of the type, such as "User Task", "Script Task", "Start Event" etc...
37 lines
964 B
Python
37 lines
964 B
Python
import time
|
|
|
|
from SpiffWorkflow.task import Task
|
|
|
|
cache_store = {}
|
|
|
|
import time
|
|
|
|
# first pass - meant to be down and dirty
|
|
def purge_cache(now):
|
|
dellist = []
|
|
for key in cache_store.keys():
|
|
if cache_store[key]['timeout'] < now:
|
|
dellist.append(key)
|
|
for key in dellist:
|
|
del cache_store[key]
|
|
|
|
def cache(f,timeout=60):
|
|
"""Cache the values for function for x minutes
|
|
we still have work to do to make a optional kw argument
|
|
to set the length of time to cache
|
|
"""
|
|
def cached(*args, **kw):
|
|
now = time.time()
|
|
purge_cache(now)
|
|
key =f.__name__+str(args)+str(kw)
|
|
if key in cache_store.keys():
|
|
return cache_store[key]['value']
|
|
else:
|
|
newtime = now+timeout*60
|
|
result = f(*args, **kw)
|
|
cache_store[key] ={}
|
|
cache_store[key]['value'] = result
|
|
cache_store[key]['timeout'] = newtime
|
|
return result
|
|
|
|
return cached |