Добавить watchdog в xmpp бота

import logging
from getpass import getpass
from argparse import ArgumentParser
from slixmpp import ClientXMPP
import time
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import subprocess
from subprocess import Popen, PIPE
import os
import sys
 
class SendMsgBot(ClientXMPP):
    def __init__(self, jid, password, recipient, message):
        ClientXMPP.__init__(self, jid, password)
        self.add_event_handler("session_start", self.session_start)
        self.add_event_handler("message", self.message)
    def session_start(self, event):
        self.send_presence()
        self.get_roster()
    def message(self, msg):
        if msg['type'] in ('chat', 'normal'):
            message_text = msg['body']
            
            if message_text.lower() == "send" :
                f = open('/tmp/watch/clip','r')
                reply = f
            msg.reply(reply).send()
 
 
#  self.disconnect()
if __name__ == '__main__':
 logging.basicConfig(level=logging.DEBUG,
 format='%(levelname)-8s %(message)s')
 f = open('/tmp/watch/clip','r') 
 
 xmpp = SendMsgBot('jid@bota.ru/slix', 'pAssWORd', 'jid@adresata.ru', f)
 xmpp.register_plugin('xep_0030') # Service Discovery
 xmpp.register_plugin('xep_0199') # XMPP Ping
 xmpp.connect()
 xmpp.process(forever=True)
 watch = OnMyWatch()
 watch.run()

import time
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
import subprocess
from subprocess import Popen, PIPE
import os
import sys
 
class OnMyWatch:
    watchDirectory = "/tmp/watch/clip"
    def __init__(self):
        self.observer = Observer()
 
    def run(self):
        event_handler = Handler()
        self.observer.schedule(event_handler, self.watchDirectory, recursive = True)
        self.observer.start()
        try:
            while True:
                time.sleep(5)
        except:
            self.observer.stop()
            print("Observer Stopped")
 
        self.observer.join()
 
 
class Handler(FileSystemEventHandler):
 
    @staticmethod
    def on_any_event(event):
        if event.event_type == 'closed': 
            print("urrrrra")
            subprocess.run (["/home/user/filesend"]) #kostyl'
 
if __name__ == '__main__':
    watch = OnMyWatch()
    watch.run()