Update cp-worker.py

DistributedScience · Sep 30, 2020 · 4f0a525 · 4f0a525
1 parent 3d03417
commit 4f0a525
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/worker/cp-worker.py b/worker/cp-worker.py
@@ -138,6 +138,7 @@ def runCellProfiler(message):
 		objectsizelist=[k['Size'] for k in bucketlist['Contents']]
 		objectsizelist = [i for i in objectsizelist if i >= MIN_FILE_SIZE_BYTES]
 		if len(objectsizelist)>=int(EXPECTED_NUMBER_FILES):
+		    logger.removeHandler(watchtowerlogger)
 		    return 'SUCCESS'
 	except KeyError: #Returned if that folder does not exist
 		pass