Feature/synced collection/replace jsondict

signac/__init__.py

@@ -28,10 +28,10 @@
 from .contrib import get_job, get_project, index, index_files, init_project
 from .core.h5store import H5Store, H5StoreManager
 from .core.jsondict import JSONDict
-from .core.jsondict import buffer_reads_writes as buffered
 from .core.jsondict import flush_all as flush
 from .core.jsondict import get_buffer_load, get_buffer_size
-from .core.jsondict import in_buffered_mode as is_buffered
+from .core.synced_collections.buffered_collection import buffer_all as buffered
+from .core.synced_collections.buffered_collection import is_buffered
 from .db import get_database
 from .diff import diff_jobs
 from .version import __version__

signac/contrib/errors.py

@@ -28,8 +28,8 @@ class DestinationExistsError(Error, RuntimeError):
 
     Parameters
     ----------
-    destination :
-        The destination object causing the error.
+    destination : str
+        The destination causing the error.
 
     """
 

signac/contrib/hashing.py

@@ -6,6 +6,9 @@
 import hashlib
 import json
 
+from ..core.synced_collections.utils import SyncedCollectionJSONEncoder
+from ..errors import KeyTypeError
+
 # We must use the standard library json for exact consistency in formatting
 
 
@@ -27,7 +30,10 @@ def calc_id(spec):
         Encoded hash in hexadecimal format.
 
     """
-    blob = json.dumps(spec, sort_keys=True)
+    try:
+        blob = json.dumps(spec, cls=SyncedCollectionJSONEncoder, sort_keys=True)
+    except TypeError:
+        raise KeyTypeError
     m = hashlib.md5()
     m.update(blob.encode())
     return m.hexdigest()

signac/contrib/import_export.py

@@ -766,7 +766,7 @@ def _copy_to_job_workspace(src, job, copytree):
             raise DestinationExistsError(job)
         raise
     else:
-        job._init()
+        job.init()
     return dst