Skip to content
Permalink
Browse files

update indent

  • Loading branch information...
TaiSakuma committed Apr 11, 2019
1 parent c408013 commit 90b7a50640cfe5248c6eaf4147388b64937c18fe
Showing with 7 additions and 7 deletions.
  1. +7 −7 alphatwirl/concurrently/WorkingArea.py
@@ -161,8 +161,8 @@ def put_package(self, package):
# e.g., '{path}/tpd_20161129_122841_HnpcmF/task_00009.p.gz'

with gzip.open(package_fullpath, 'wb') as f:
pickle.dump(package, f, protocol=pickle.HIGHEST_PROTOCOL)
f.close()
pickle.dump(package, f, protocol=pickle.HIGHEST_PROTOCOL)
f.close()

result_fullpath = self.result_fullpath(package_index)
# e.g., '{path}/tpd_20161129_122841_HnpcmF/results/task_00009/result.p.gz'
@@ -193,12 +193,12 @@ def collect_result(self, package_index):
# e.g., '{path}/tpd_20161129_122841_HnpcmF/results/task_00009/result.p.gz'

try:
with gzip.open(result_fullpath, 'rb') as f:
result = pickle.load(f)
with gzip.open(result_fullpath, 'rb') as f:
result = pickle.load(f)
except Exception as e:
logger = logging.getLogger(__name__)
logger.warning(e)
return None
logger = logging.getLogger(__name__)
logger.warning(e)
return None

return result

0 comments on commit 90b7a50

Please sign in to comment.
You can’t perform that action at this time.