1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
if __name__ == "__main__":
import eventlet
eventlet.monkey_patch()
import signal
import sys
import tempfile
from watchdog.events import LoggingEventHandler
from watchdog.observers import Observer
with tempfile.TemporaryDirectory() as temp_dir:
def run_observer():
event_handler = LoggingEventHandler()
observer = Observer()
observer.schedule(event_handler, temp_dir)
observer.start()
eventlet.sleep(1)
observer.stop()
def on_alarm(signum, frame):
print("Observer.stop() never finished!", file=sys.stderr) # noqa: T201
sys.exit(1)
signal.signal(signal.SIGALRM, on_alarm)
signal.alarm(4)
thread = eventlet.spawn(run_observer)
thread.wait()
|
