|
|
|
@ -13,7 +13,7 @@
|
|
|
|
import json
|
|
|
|
import json
|
|
|
|
from threading import Thread
|
|
|
|
from threading import Thread
|
|
|
|
import os
|
|
|
|
import os
|
|
|
|
import zipfile
|
|
|
|
import shutil
|
|
|
|
import subprocess
|
|
|
|
import subprocess
|
|
|
|
from monitor import ProcessCounter
|
|
|
|
from monitor import ProcessCounter
|
|
|
|
from utils.transport import QueueListener, QueueWriter, QueueReader
|
|
|
|
from utils.transport import QueueListener, QueueWriter, QueueReader
|
|
|
|
@ -82,7 +82,9 @@ class Folders(Actor):
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
This function consists in deleting files from a given folder
|
|
|
|
This function consists in deleting files from a given folder
|
|
|
|
"""
|
|
|
|
"""
|
|
|
|
pass
|
|
|
|
shutil.rmtree(item['label'])
|
|
|
|
|
|
|
|
os.mkdir(item['label'])
|
|
|
|
|
|
|
|
|
|
|
|
def isvalid(self,item):
|
|
|
|
def isvalid(self,item):
|
|
|
|
return os.path.exists(item['label'])
|
|
|
|
return os.path.exists(item['label'])
|
|
|
|
def process(self,item):
|
|
|
|
def process(self,item):
|
|
|
|
|
