Merge pull request #800 from pwolfram/dask_async_lock_fix

Adds dask lock capability for backend writes

Author: shoyer

xarray/backends/common.py

@@ -3,6 +3,7 @@
 import logging
 import time
 import traceback
+import threading
 from collections import Mapping
 
 from ..conventions import cf_encoder
@@ -162,7 +163,11 @@ def add(self, source, target):
     def sync(self):
         if self.sources:
             import dask.array as da
-            da.store(self.sources, self.targets)
+            import dask
+            if dask.__version__ > '0.8.1':
+                da.store(self.sources, self.targets, lock=threading.Lock())
+            else:
+                da.store(self.sources, self.targets)
             self.sources = []
             self.targets = []