diff --git a/confluent_server/confluent/messages.py b/confluent_server/confluent/messages.py index cf3d4707..3fc63b8e 100644 --- a/confluent_server/confluent/messages.py +++ b/confluent_server/confluent/messages.py @@ -545,9 +545,21 @@ class InputFirmwareUpdate(ConfluentMessage): raise Exception('User requested substitutions, but code is ' 'written against old api, code must be fixed or ' 'skip {} expansion') + if self.filebynode[node].startswith('/etc/confluent'): + raise Exception( + 'File transfer with /etc/confluent is not supported') + if self.filebynode[node].startswith('/var/log/confluent'): + raise Exception( + 'File transfer with /var/log/confluent is not supported') return self._filename def nodefile(self, node): + if self.filebynode[node].startswith('/etc/confluent'): + raise Exception( + 'File transfer with /etc/confluent is not supported') + if self.filebynode[node].startswith('/var/log/confluent'): + raise Exception( + 'File transfer with /var/log/confluent is not supported') return self.filebynode[node] class InputMedia(InputFirmwareUpdate):