Merge pull request #1216 from abridgett/abridgett/1215_slackclient_re…

…turns_decoded_dict [#1215] slackclient v1.0.0 returns a decoded dict
apache · Apr 2, 2016 · 526e564 · 526e564
1 parent 3101825
commit 526e564
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/operators/slack_operator.py b/airflow/operators/slack_operator.py
@@ -50,7 +50,7 @@ def execute(self, **kwargs):
         if not self.api_params:
             self.construct_api_call_params()
         sc = SlackClient(self.token)
-        rc = json.loads(sc.api_call(self.method, **self.api_params).decode('utf-8'))
+        rc = sc.api_call(self.method, **self.api_params)
         if not rc['ok']:
             logging.error("Slack API call failed ({})".format(rc['error']))
             raise AirflowException("Slack API call failed: ({})".format(rc['error']))