projects
/
htsworkflow.git
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
68fe895
)
pyinotify rm_watch takes a list, not a dictionary.
author
Diane Trout
<diane@caltech.edu>
Tue, 15 Jan 2008 23:46:04 +0000
(23:46 +0000)
committer
Diane Trout
<diane@caltech.edu>
Tue, 15 Jan 2008 23:46:04 +0000
(23:46 +0000)
gaworkflow/automation/spoolwatcher.py
patch
|
blob
|
history
diff --git
a/gaworkflow/automation/spoolwatcher.py
b/gaworkflow/automation/spoolwatcher.py
index ba566cbfa04957e69c813302aa9e701fa0952a9d..1be91c8254a0877c7ee96c7bdc08042919fdc11f 100644
(file)
--- a/
gaworkflow/automation/spoolwatcher.py
+++ b/
gaworkflow/automation/spoolwatcher.py
@@
-11,6
+11,16
@@
from pyinotify import EventsCodes
from benderjab import rpc
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):
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))
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):
self.wdd = None
def process_notify(self, *args):