Fix correct param passing from Airflow to HOP

damavis · May 29, 2024 · 2a1f904 · 2a1f904
1 parent bc717c9
commit 2a1f904
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/airflow_hop/operators.py b/airflow_hop/operators.py
@@ -57,14 +57,14 @@ def __init__(self,
                  log_level,
                  *args,
                  environment=None,
-                 params=None,
+                 hop_params=None,
                  hop_conn_id='hop_default',
                  **kwargs):
         super().__init__(*args, **kwargs)
         self.workflow = workflow
         self.project_name = project_name
         self.log_level = log_level
-        self.task_params = params
+        self.task_params = hop_params
         self.hop_conn_id = hop_conn_id
         self.environment = environment
 
@@ -120,7 +120,7 @@ def __init__(self,
                  log_level,
                  *args,
                  environment=None,
-                 params=None,
+                 hop_params=None,
                  hop_conn_id='hop_default',
                  **kwargs):
         super().__init__(*args, **kwargs)
@@ -129,7 +129,7 @@ def __init__(self,
         self.project_name = project_name
         self.log_level = log_level
         self.hop_conn_id = hop_conn_id
-        self.task_params = params
+        self.task_params = hop_params
         self.environment = environment
 
     def __get_hop_client(self):