Fabric - Monitor files for change and execute tasks using inotify (like inotifywait) #1295

fabric_file_monitor.py

import inotifyx
from glob import glob

def _run_monitoring_loop(fd, globs, tasks):
    """Setup file monitoring and run Fabric tasks
    """

    fnames = [fn for g in globs for fn in glob(g)]
    if len(fnames) > 5:
        print("Monitoring %d files..." % len(fnames))
    else:
        print("Monitoring %s..." % ','.join(sorted(fnames)))

    for fn in fnames:
        inotifyx.add_watch(fd, fn, inotifyx.IN_CLOSE_WRITE)

    inotifyx.get_events(fd)
    for t in tasks:
        execute(t)


def monitor_files(globs, tasks):
    """Monitor files for change and execute tasks until interrupted.
    globs: file globbing (str) or an iterable of globbings
    tasks: fabric task or an iterable of tasks
    """
    if not isinstance(globs, (list, tuple)):
        globs = (globs, )

    if not isinstance(tasks, (list, tuple)):
        tasks = (tasks, )

    fd = inotifyx.init()
    try:
        while True:
            _run_monitoring_loop(fd, globs, tasks)

    finally:
        os.close(fd)