Permalink
Browse files

Merge pull request #26 from datasift/bug/push-output-params-prefix

PushDefinition automatically prefixes output param
  • Loading branch information...
dugjason committed Jan 16, 2013
2 parents 29e4613 + 361f779 commit 2dddb7ddb90abf6456bebd65f23afd1ef9d5752c
Showing with 3 additions and 3 deletions.
  1. +3 −3 datasift/__init__.py
View
@@ -917,7 +917,7 @@ def get_output_param(self, key):
"""
Get an output parameter.
"""
- return self._output_params[key]
+ return self._output_params[self.OUTPUT_PARAMS_PREFIX + key]
def get_output_params(self):
"""
@@ -929,7 +929,7 @@ def set_output_param(self, key, val):
"""
Set an output parameter.
"""
- self._output_params[key] = val
+ self._output_params[self.OUTPUT_PARAMS_PREFIX + key] = val
def validate(self):
"""
@@ -977,7 +977,7 @@ def subscribe(self, hash_type, hash, name):
'output_type': self.get_output_type()
}
for key in self._output_params:
- params[self.OUTPUT_PARAMS_PREFIX + key] = self._output_params[key]
+ params[key] = self._output_params[key]
if len(self.get_initial_status()) > 0:
params['initial_status'] = self.get_initial_status()

0 comments on commit 2dddb7d

Please sign in to comment.