fix fusion params

singlestore-labs · Jul 29, 2024 · 05750fe · 05750fe
1 parent 11ba0fe
commit 05750fe
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/singlestoredb/fusion/handlers/job.py b/singlestoredb/fusion/handlers/job.py
@@ -130,9 +130,9 @@ def run(self, params: Dict[str, Any]) -> Optional[FusionSQLResult]:
 
         parameters = None
         if params.get('with_parameters'):
-            parameters = []
+            parameters = {}
             for name, value in params['with_parameters'].items():
-                parameters.append((name, value))
+                parameters[name] = value
 
         execution_interval_in_mins = params['execute_every'][0]['interval']
         time_unit = params['execute_every'][-1]['time_unit'].upper()
@@ -228,9 +228,9 @@ def run(self, params: Dict[str, Any]) -> Optional[FusionSQLResult]:
 
         parameters = None
         if params.get('with_parameters'):
-            parameters = []
+            parameters = {}
             for name, value in params['with_parameters'].items():
-                parameters.append((name, value))
+                parameters[name] = value
 
         job = jobs_manager.run(
             params['notebook_path'],