def execute(self, **kwargs):
        if not self.api_params:
            self.construct_api_call_params()
        sc = SlackClient(self.token)
        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']))
SlackAPIOperator calls will not fail even if the call is not unsuccessful.
dataset/ETHPy150Open airbnb/airflow/airflow/operators/slack_operator.py/SlackAPIOperator.execute