in SamplesV2/AzureBatchIntegration/src/decompressor.py [0:0]
def init(self, local_temp_dir):
if os.path.exists(local_temp_dir):
shutil.rmtree(local_temp_dir)
try:
os.makedirs(local_temp_dir)
except OSError as exc: # Guard against race condition
if exc.errno != errno.EEXIST:
raise