class Handler(pyinotify.ProcessEvent):
def __init__(self, watchmanager, bot, completion_files=None):
class Handler(pyinotify.ProcessEvent):
def __init__(self, watchmanager, bot, completion_files=None):
# if we've already seen an event in this directory (AKA runfolder)
# keep track if its already hit the "completed" flag
# if we've already seen an event in this directory (AKA runfolder)
# keep track if its already hit the "completed" flag
run_already_complete = watch_path_events[target].complete
watch_path_events[target] = WatcherEvent(target)
run_already_complete = watch_path_events[target].complete
watch_path_events[target] = WatcherEvent(target)
self.wdds.append(self.wm.add_watch(w, mask, rec=True, auto_add=True))
def unmount_watch(self, event_path):
self.wdds.append(self.wm.add_watch(w, mask, rec=True, auto_add=True))
def unmount_watch(self, event_path):
# the list getting shorter
for i in range(len(self.wdds),0, -1):
wdd = self.wdds[i]
# the list getting shorter
for i in range(len(self.wdds),0, -1):
wdd = self.wdds[i]
self.notifier.read_events()
# should we do something?
# has something happened?
self.notifier.read_events()
# should we do something?
# has something happened?
- for watchdir, last_events in self.handler.last_event.items():
- for last_event_dir, last_event_detail in last_events.items():
+ for watchdir, last_events in list(self.handler.last_event.items()):
+ for last_event_dir, last_event_detail in list(last_events.items()):
copy_url = self.make_copy_url(watchdir, last_event_dir)
self.startCopy(copy_url)
if last_event_detail.complete:
copy_url = self.make_copy_url(watchdir, last_event_dir)
self.startCopy(copy_url)
if last_event_detail.complete:
- help = u"I can send [copy] message, or squencer [finished]"
- if re.match(u"help", msg):
+ help = "I can send [copy] message, or squencer [finished]"
+ if re.match("help", msg):
- reply = u"sent copy message"
- elif re.match(u"finished", msg):
+ reply = "sent copy message"
+ elif re.match("finished", msg):