adulau/aha
1
0
Fork 0
mirror of https://github.com/adulau/aha.git synced 2024-12-27 11:16:11 +00:00
Code Issues Projects Releases Packages Wiki Activity

Try #0 fix IOError from aha - worker

Browse source
This commit is contained in:
Gerard Wagener 2010-01-21 13:58:49 +01:00
parent 3008f3ba7c
commit 750e4c71f1
1 changed files with 2 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
aha/aha-worker.py
View file

@ -36,6 +36,8 @@ class PeriodTaks():
def remove_old_msg(self,queue): def remove_old_msg(self,queue):
#Get current date if the files are older than the timeout remove them #Get current date if the files are older than the timeout remove them
t0 = int(time.strftime("%s")) t0 = int(time.strftime("%s"))
#FIXME os.walkdir, os.listdir could also be used
dircache.reset()
files = dircache.listdir(queue) files = dircache.listdir(queue)
for file in files: for file in files:
af = queue + os.sep + file af = queue + os.sep + file