Fixes #155 Currently setting @configuration(distributed=True) results in a command that is NOT distributed.

Author: datasearchninja

splunklib/searchcommands/generating_command.py

@@ -308,7 +308,7 @@ def iteritems(self):
             version = self.command.protocol_version
             if version == 2:
                 iteritems = ifilter(lambda (name, value): name != 'distributed', iteritems)
-                if self.distributed and self.type == 'streaming':
+                if not self.distributed and self.type == 'streaming':
                     iteritems = imap(
                         lambda (name, value): (name, 'stateful') if name == 'type' else (name, value), iteritems)
             return iteritems

splunklib/searchcommands/streaming_command.py

@@ -180,7 +180,7 @@ def iteritems(self):
                     iteritems = ifilter(lambda (name, value): name != 'clear_required_fields', iteritems)
             else:
                 iteritems = ifilter(lambda (name, value): name != 'distributed', iteritems)
-                if self.distributed:
+                if not self.distributed:
                     iteritems = imap(
                         lambda (name, value): (name, 'stateful') if name == 'type' else (name, value), iteritems)
             return iteritems