Merge pull request #23 from damavis/hotfix/fix-params-on-kettle-pan-run

Fix params on kettle pan command run.
damavis · Dec 1, 2022 · 6986351 · 6986351
2 parents 9df34e2 + f79b70c
commit 6986351
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow_pentaho/operators/kettle.py b/airflow_pentaho/operators/kettle.py
@@ -200,7 +200,7 @@ def execute(self, context):  # pylint: disable=unused-argument
             arguments.update({'file': self.file})
             arguments.update({'norep': 'true'})
 
-        self.command_line = conn.build_command('pan', arguments, self.params)
+        self.command_line = conn.build_command('pan', arguments, self.task_params)
         output = self._run_command()
 
         if self.xcom_push_flag: