Commit c372d50a authored by Daniel Scheffler's avatar Daniel Scheffler
Browse files

Properly close and join multiprocessing.Pool to make coverage work in multiprocessing.



Signed-off-by: Daniel Scheffler's avatarDaniel Scheffler <danschef@gfz-potsdam.de>
parent deb816a8
Pipeline #36264 failed with stage
in 4 minutes and 55 seconds
...@@ -403,6 +403,8 @@ class Tie_Point_Grid(object): ...@@ -403,6 +403,8 @@ class Tie_Point_Grid(object):
# COREG and is not raised # COREG and is not raised
results = results.get() results = results.get()
break break
pool.close() # needed to make coverage work in multiprocessing
pool.join()
else: else:
# declare global variables needed for self._get_spatial_shifts() # declare global variables needed for self._get_spatial_shifts()
...@@ -974,6 +976,8 @@ class Tie_Point_Grid(object): ...@@ -974,6 +976,8 @@ class Tie_Point_Grid(object):
# #
# with multiprocessing.Pool() as pool: # with multiprocessing.Pool() as pool:
# self.kriged = pool.map(self.Kriging_mp,args_kwargs_dicts) # self.kriged = pool.map(self.Kriging_mp,args_kwargs_dicts)
# pool.close() # needed to make coverage work in multiprocessing
# pool.join()
# else: # else:
# self.Kriging_sp(attrName,skip_nodata=skip_nodata,skip_nodata_col=skip_nodata_col, # self.Kriging_sp(attrName,skip_nodata=skip_nodata,skip_nodata_col=skip_nodata_col,
# outGridRes=outGridRes,fName_out=fName_out,tilepos=tilepos) # outGridRes=outGridRes,fName_out=fName_out,tilepos=tilepos)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment