code: def _enqueue_fs_event(self, event):
      
      self._logger.info('enqueuing {} changes for subscription {}'
                        .format(len(event['files']), event['subscription']))
      self._event_queue.put(event)
docs: Watchman filesystem event handler for BUILD/requirements.txt updates. Called via a thread.