code: def _get_task_kwargs(self):
          
          res = {}
          for (param_name, param_obj) in self._get_task_cls().get_params():
              attr = getattr(self.known_args, param_name)
              if attr:
                  res.update(((param_name, param_obj.parse(attr)),))
  
          return res
docs: Get the local task arguments as a dictionary. The return value is in
          the form ``dict(my_param='my_value', ...)``