fixd

somewheve · somewheve · commit 188e239fecd3 · 2025-02-26T17:31:16.000+08:00
diff --git a/hive/__pycache__/task.cpython-39.pyc b/hive/__pycache__/task.cpython-39.pyc
diff --git a/hive/cmd.py b/hive/cmd.py
@@ -49,8 +49,8 @@ def run_command(name, path, ff, cf, rd, dispatch, tick_save, config_path):
                   "tick_save": tick_save,
                   }
     logger.info(f"read config: {config}")
-    insert = DataUpdateTask(config)
-    clean = CleanDataTask(config)
+    insert = DataUpdateTask(**config)
+    clean = CleanDataTask(**config)
     hive = Hive()
     hive.config.from_mapping(config)
     hive.insert(insert, clean)
diff --git a/hive/src/task.py b/hive/src/task.py
@@ -25,7 +25,7 @@ def should_run(self, c_time: datetime) -> bool:
 
 
 class CleanDataTask(OnceTask):
-    def __init__(self):
+    def __init__(self, **kwargs):
         super().__init__("数据清洗")
 
     def run(self):
