Permalink
Browse files
Remove occasional camel-casing of app caching (#1439)
- Loading branch information...
Showing
with
4 additions
and
4 deletions.
-
+2
−2
docs/userguide/checkpoints.rst
-
+1
−1
parsl/app/app.py
-
+1
−1
parsl/dataflow/memoization.py
|
|
@@ -7,8 +7,8 @@ Large scale workflows are prone to errors due to node failures, application or e |
|
|
Parsl's checkpointing model provides workflow resilience and fault tolerance. |
|
|
|
|
|
.. note:: |
|
|
Checkpointing is *only* possible for apps which have AppCaching enabled. |
|
|
If AppCaching is disabled in the config ``Config.app_cache``, checkpointing will |
|
|
Checkpointing is *only* possible for apps which have app caching enabled. |
|
|
If app caching is disabled in the config ``Config.app_cache``, checkpointing will |
|
|
**not** work. |
|
|
|
|
|
Parsl follows an incremental checkpointing model, where each checkpoint file contains |
|
|
|
|
|
@@ -53,7 +53,7 @@ def __init__(self, func, data_flow_kernel=None, walltime=60, executors='all', ca |
|
|
try: |
|
|
self.fn_source = getsource(func) |
|
|
except OSError: |
|
|
logger.warning("Unable to get source code for AppCaching. Recommend creating module") |
|
|
logger.warning("Unable to get source code for app caching. Recommend creating module") |
|
|
self.fn_source = func.__name__ |
|
|
|
|
|
self.func_hash = md5(self.fn_source.encode('utf-8')).hexdigest() |
|
|
|
|
|
@@ -139,7 +139,7 @@ def update_memo(self, task_id, task, r): |
|
|
return |
|
|
|
|
|
if task['hashsum'] in self.memo_lookup_table: |
|
|
logger.info('Updating appCache entry with latest %s:%s call' % |
|
|
logger.info('Updating app cache entry with latest %s:%s call' % |
|
|
(task['func_name'], task_id)) |
|
|
self.memo_lookup_table[task['hashsum']] = r |
|
|
else: |
|
|
|
0 comments on commit
a0b7636