Handling params the same way as kettle hook. (#27)

airflow_pentaho/hooks/carte.py

@@ -108,8 +108,13 @@ def run_job(self, job_path, params=None):
                 'level': self.level
             }
 
-            if params:
-                args.update(params)
+            if params is not None:
+                for k, val in params.items():
+                    if version.parse(airflow.__version__) >= version.parse('2.2') and \
+                            not isinstance(val, str):
+                        args[k] = val.value
+                    else:
+                        args[k] = val
 
             rs = requests.get(url=url, params=args, auth=self.__get_auth())
             if rs.status_code >= 400:

requirements.txt

@@ -3,3 +3,4 @@ setuptools-git-version
 pytest
 pytest-cov
 twine
+toml