pyinotify rm_watch takes a list, not a dictionary.
authorDiane Trout <diane@caltech.edu>
Tue, 15 Jan 2008 23:46:04 +0000 (23:46 +0000)
committerDiane Trout <diane@caltech.edu>
Tue, 15 Jan 2008 23:46:04 +0000 (23:46 +0000)
gaworkflow/automation/spoolwatcher.py

index ba566cbfa04957e69c813302aa9e701fa0952a9d..1be91c8254a0877c7ee96c7bdc08042919fdc11f 100644 (file)
@@ -11,6 +11,16 @@ from pyinotify import EventsCodes
 
 from benderjab import rpc
 
+class WatcherEvents(object):
+    # two events need to be tracked
+    # one to send startCopy
+    # one to send OMG its broken
+    # OMG its broken needs to stop when we've seen enough
+    #  cycles
+    # this should be per runfolder. 
+    # read the xml files 
+    def __init__(self):
+        
 
 class Handler(pyinotify.ProcessEvent):
     def __init__(self, watchmanager, bot):
@@ -112,7 +122,7 @@ class SpoolWatcher(rpc.XmlRpcBot):
         if self.wdd is not None:
             logging.debug("disabling watch")
             logging.debug(str(self.wdd))
-            self.wm.rm_watch(self.wdd)
+            self.wm.rm_watch(self.wdd.values())
             self.wdd = None
             
     def process_notify(self, *args):