(self, directory, filenames)
| 511 | self.client.query("subscribe", root, name, query) |
| 512 | |
| 513 | def _subscribe_dir(self, directory, filenames): |
| 514 | if not directory.exists(): |
| 515 | if not directory.parent.exists(): |
| 516 | logger.warning( |
| 517 | "Unable to watch directory %s as neither it or its parent exist.", |
| 518 | directory, |
| 519 | ) |
| 520 | return |
| 521 | prefix = "files-parent-%s" % directory.name |
| 522 | filenames = ["%s/%s" % (directory.name, filename) for filename in filenames] |
| 523 | directory = directory.parent |
| 524 | expression = ["name", filenames, "wholename"] |
| 525 | else: |
| 526 | prefix = "files" |
| 527 | expression = ["name", filenames] |
| 528 | self._subscribe(directory, "%s:%s" % (prefix, directory), expression) |
| 529 | |
| 530 | def _watch_glob(self, directory, patterns): |
| 531 | """ |
no test coverage detected